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