bug fixed ps_sub thread join

zhangmeng

2023-03-01 0f53806de20f07b0bc15877c7a9b293758acbfa7

 src/nng_wrap.cpp

@@ -205,7 +205,7 @@
        PRNTVITAG("client_socket faild\n");
        return -1;
    }
    // set_socket_timeout(sock, timeout_req_rep);
    set_socket_timeout(sock, 300);
    sub->socket_ = sock;
    sub->t_ = get_thread([](const auto sub){
        while (!sub->t_quit_.load()) {
@@ -246,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()));
            }
        }