c++ - ZeroMQ后台线程创建

Question

我正在尝试了解 ZeroMQ 的线程模型。

根据他们的白皮书http://zeromq.org/whitepapers:architecture#toc3 ，创建上下文的每个 I/O 线程直接映射到操作系统线程。我不明白的是为什么这个最小程序会产生两个后台线程:

#include <zmq.hpp>

int main() {
    zmq::context_t context{1};
    zmq::socket_t socket(context, ZMQ_SUB);
    socket.setsockopt(ZMQ_SUBSCRIBE, "", 0);
    socket.connect("tcp://localhost:5555");

}

如以下 gdb 输出所示，创建套接字的行产生了两个后台线程。

Breakpoint 3, 0x00007f3cbebfbc80 in clone () from /lib64/libc.so.6
(gdb) bt
#0  0x00007f3cbebfbc80 in clone () from /lib64/libc.so.6
#1  0x00007f3cbdff7f7a in do_clone.constprop () from /lib64/libpthread.so.0
#2  0x00007f3cbdff9469 in pthread_create@@GLIBC_2.2.5 () from /lib64/libpthread.so.0
#3  0x00007f3cbf74547d in zmq::thread_t::start(void (*)(void*), void*) () from /lib64/libzmq.so.5
#4  0x00007f3cbf70044a in zmq::ctx_t::start_thread(zmq::thread_t&, void (*)(void*), void*) const () from /lib64/libzmq.so.5
#5  0x00007f3cbf7012c1 in zmq::ctx_t::create_socket(int) () from /lib64/libzmq.so.5
#6  0x0000000000401251 in zmq::socket_t::init (this=0x7ffd5d0323f0, context_=..., type_=2) at /usr/include/zmq.hpp:649
#7  0x00000000004010a1 in zmq::socket_t::socket_t (this=0x7ffd5d0323f0, context_=..., type_=2) at /usr/include/zmq.hpp:463
#8  0x0000000000400e2f in main () at sub.cpp:5
(gdb) c
Continuing.
[New Thread 0x7f3cbc7e6700 (LWP 15499)]

Breakpoint 3, 0x00007f3cbebfbc80 in clone () from /lib64/libc.so.6
(gdb) bt
#0  0x00007f3cbebfbc80 in clone () from /lib64/libc.so.6
#1  0x00007f3cbdff7f7a in do_clone.constprop () from /lib64/libpthread.so.0
#2  0x00007f3cbdff9469 in pthread_create@@GLIBC_2.2.5 () from /lib64/libpthread.so.0
#3  0x00007f3cbf74547d in zmq::thread_t::start(void (*)(void*), void*) () from /lib64/libzmq.so.5
#4  0x00007f3cbf70044a in zmq::ctx_t::start_thread(zmq::thread_t&, void (*)(void*), void*) const () from /lib64/libzmq.so.5
#5  0x00007f3cbf70135f in zmq::ctx_t::create_socket(int) () from /lib64/libzmq.so.5
#6  0x0000000000401251 in zmq::socket_t::init (this=0x7ffd5d0323f0, context_=..., type_=2) at /usr/include/zmq.hpp:649
#7  0x00000000004010a1 in zmq::socket_t::socket_t (this=0x7ffd5d0323f0, context_=..., type_=2) at /usr/include/zmq.hpp:463
#8  0x0000000000400e2f in main () at sub.cpp:5
(gdb) c
Continuing.
[New Thread 0x7f3cbbfe5700 (LWP 15500)]

Breakpoint 4, main () at sub.cpp:6
6       socket.setsockopt(ZMQ_SUBSCRIBE, "", 0);
(gdb) info thread
  Id   Target Id         Frame 
  3    Thread 0x7f3cbbfe5700 (LWP 15500) "a" 0x00007f3cbebfc2c3 in epoll_wait () from /lib64/libc.so.6
  2    Thread 0x7f3cbc7e6700 (LWP 15499) "a" 0x00007f3cbebfc2c3 in epoll_wait () from /lib64/libc.so.6
* 1    Thread 0x7f3cbfb4e840 (LWP 15498) "a" main () at sub.cpp:6
(gdb)

使用 ZeroMQ 和 cppzmq-devel 4.1.4
使用:g++ -std=c++11 -g sub.cpp -lzmq

Answer 1

why two background threads are spawned by this minimal program ?

_{首先，[+1] 用于发布版本详细信息和基于证据的论证}

ZeroMQ 是一种无代理的异步消息传递基础设施，围绕 Context()-实例构建。如果不熟悉 ZeroMQ 方式，可以花 5 秒阅读 [ ZeroMQ hierarchy in less than a five seconds 中的主要概念元素。 ] 部分。

鉴于事实，总是有机会定义在要实例化的 Context( nIOthreads = 1 ) 中生成多少 IO 线程，让我们简而言之:

• 配备零 IO 线程的 Context( 0 )
  将自身生成为线程 + 0 IO 线程，即 1 个线程
• 一个单独的 IO 线程配备 Context( 1 )
  将自己生成一个线程 + 1 IO 线程，即 2 个线程
• 一个配备了更多 IO 线程的 Context( N )
  将自身生成为一个线程 + N IO 线程，即 1+N 个线程

鉴于上述实验，体内的真实成分可以很容易地得到验证。

可以很容易地想象线程在 Context() 实例中的特殊化作用，其中与传输类相关的问题与 Context() 的主要任务分开，即进行内务管理 + 管理所有 FSA/工作流 + 使用应用程序端代码在其本地接口(interface)上保持异步通信服务。

以同样的方式，传输类 inproc://，没有真正的传输相关设备来控制，可以在 IO 中工作-thread-less Context() 实例，其中仅内存映射跨“边界”工作，具有所有应有的本地进程内存，但无需操作任何 IO 线程。

Martin Sústrik 等人如何定义和微调 ZeroMQ 架构，这是一种聪明而酷的方式。感谢他们!