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