From 5d5ff8efc5bd1d6fd27e5f46b4ab68523e061b3e Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期三, 14 十二月 2022 17:48:10 +0800
Subject: [PATCH] optimize cpu
---
src/nng_wrap.cpp | 5 +++--
1 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/src/nng_wrap.cpp b/src/nng_wrap.cpp
index f2c22c4..c3b835f 100644
--- a/src/nng_wrap.cpp
+++ b/src/nng_wrap.cpp
@@ -210,7 +210,8 @@
sub->t_ = get_thread([](const auto sub){
while (!sub->t_quit_.load()) {
char* m{};
- int m_len = nn_recv(sub->socket_, &m, NN_MSG, NN_DONTWAIT);
+ // int m_len = nn_recv(sub->socket_, &m, NN_MSG, NN_DONTWAIT);
+ int m_len = nn_recv(sub->socket_, &m, NN_MSG, 0);
if (m_len > 0){
string tmp_msg{m, (size_t)m_len};
nn_freemsg(m);
@@ -245,7 +246,7 @@
}
}
}
- this_thread::sleep_for(chrono::milliseconds{6});
+ // this_thread::sleep_for(chrono::milliseconds{6});
// printf("======>> subscribe nn_recv failed %s\n", nn_strerror(nn_errno()));
}
}
--
Gitblit v1.8.0