optimize cpu

zhangmeng

2022-12-14 5d5ff8efc5bd1d6fd27e5f46b4ab68523e061b3e

 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()));
            }
        }