From e9984ced808cdd0be956630e25a431853c91e478 Mon Sep 17 00:00:00 2001 From: zhangmeng <775834166@qq.com> Date: 星期二, 21 十二月 2021 10:43:57 +0800 Subject: [PATCH] performance --- src/req_rep.cpp | 9 +++++---- 1 files changed, 5 insertions(+), 4 deletions(-) diff --git a/src/req_rep.cpp b/src/req_rep.cpp index 967d586..bbd7796 100644 --- a/src/req_rep.cpp +++ b/src/req_rep.cpp @@ -85,10 +85,11 @@ string msg{(const char*)nng_msg_body(om), nng_msg_len(om)}; nng_msg_free(om); + auto t = (*rep)(); lock_guard<mutex> l{rep->mtx_msg_}; - rep->works_.emplace(rep->work_index_, w); - rep->msg_.emplace(rep->work_index_, move(msg)); - rep->work_index_++; + rep->works_.emplace(get<0>(t), w); + get<1>(t).emplace(get<0>(t), move(msg)); + get<0>(t)++; rep->cv_msg_.notify_all(); } @@ -124,7 +125,7 @@ return rv; } - work** works = (work**)malloc(sizeof(work*) * count); + work** works = (work**)malloc(sizeof(void*) * count); for (int i = 0; i < count; i++) { works[i] = alloc_work(*sock, rep); } -- Gitblit v1.8.0