[fix] pzmq close wait

dianjixz · dianjixz · commit 3a162591cf53 · 2025-11-07T09:13:57.000+08:00
diff --git a/ext_components/StackFlow/stackflow/pzmq.hpp b/ext_components/StackFlow/stackflow/pzmq.hpp
@@ -394,6 +394,8 @@ class pzmq {
     }
     void close_zmq()
     {
+        int linger = 0;
+        zmq_setsockopt(zmq_socket_, ZMQ_LINGER, &linger, sizeof(linger));
         zmq_close(zmq_socket_);
         zmq_ctx_destroy(zmq_ctx_);
         if ((mode_ == ZMQ_PUB) || (mode_ == ZMQ_PULL) || (mode_ == ZMQ_RPC_FUN)) {

Original file line number	Diff line number	Diff line change
`@@ -394,6 +394,8 @@ class pzmq {`
`394`	`394`	`}`
`395`	`395`	`void close_zmq()`
`396`	`396`	`{`
	`397`	`+ int linger = 0;`
	`398`	`+ zmq_setsockopt(zmq_socket_, ZMQ_LINGER, &linger, sizeof(linger));`
`397`	`399`	`zmq_close(zmq_socket_);`
`398`	`400`	`zmq_ctx_destroy(zmq_ctx_);`
`399`	`401`	`if ((mode_ == ZMQ_PUB) \|\| (mode_ == ZMQ_PULL) \|\| (mode_ == ZMQ_RPC_FUN)) {`