ctx_t
在创建ctx_t时,会设置以下参数
_io_thread_count io线程数默认是1
_max_sockets最大socket数是1023
_starting标识设置为true,此时socket还没有创建
_terminating设置为false,在调用zmq_ctx_term时该标识会设置为true
_tag设置为ZMQ_CTX_TAG_VALUE_GOOD,表示该对象是上下文
_reaper线程设置为null
_max_msgsz消息最大大小为INT_MAX
_blocky设置为true,表示终止时ctx会等待
_ipv6设置为false,不允许ipv6
_zero_copy设置为true,解码使用零拷贝
#define ZMQ_IO_THREADS_DFLT 1
#define ZMQ_MAX_SOCKETS_DFLT 1023
session与engine,session为用户线程与io线程交互的桥梁,两者之间是通过mailbox来交互数据,实际上是通过pipe来交换数据
ctx中的_term_mailbox在terminate方法中,会等待reaper线程发送command_t::done命令,而reapter线程在处理command_t::stop和command_t::reaped命令时,如果其管理的socket_base的个数为0,才会发送command_t::done
command_t::reaped的命令是由谁来下发的呢?
是由socket_base_t下发,在两个地方会下发,start_reaping和in_event方法中,在调用check_destroy方法时
command_t::stop的命令是由谁来下发的呢?
由reaper自己,在调用stop方法时
start_reaping什么时候会触发呢?
在socket_base_t调用close方法时,即zmq_close时。会向reaper发送command_t::reap命令,同时将自己作为参数。
start_reaping中会调用terminate方法,在process_term方法中会调用process_destroy,socket_base_t中的process_destroy会将_destroyed标识设置为true.