Memcached线程模型详解：初始化与事件注册

本文主要介绍了Memcached的网络模型，特别是初始化workers线程和连接处理机制。Memcached采用主-工作线程模型，其中主线程负责监听客户端连接，而工作者线程处理已建立连接的读写事件。 在Memcached启动过程中，主线程首先初始化，创建一个event_base实例`main_base`，接着初始化所有工作线程。每个工作线程有自己的事件库和一个由主线程分配的连接队列（CQ队列）。主线程还会创建监听socket，并将监听socket的libevent事件注册到`main_base`上，进入事件循环等待连接请求。 当有新连接到来时，主线程accept连接，然后将新建立的socket描述符（sfd）和相关数据放入工作线程的CQ队列中。每个工作线程会监控自己的CQ队列，当有可读事件时，调用`conn_new()`函数。`conn_new()`函数从队列中取出CQ_ITEM，使用libevent注册`event_handler`函数，绑定到该socket的读事件上。这样，当连接有可读数据时，`event_handler`会被调用，进一步驱动`drive_machine`执行，处理客户端的请求。 工作线程结构体包含以下几个关键部分： 1. `thread_id`：线程的唯一标识。 2. `CQ队列`：存放主线程传递过来的待处理连接。 3. `通知pipe`：用于主线程与工作线程之间的通信。 4. `libevent实例`：每个工作线程有自己的事件库，用于处理连接事件。 5. `suffix_cache`：用于CAS和GETS指令的数据一致性检查。 `conn_new()`函数的核心是将新连接注册到工作线程的libevent事件库，设置为EV_READ|EV_PERSIST，确保即使在网络断开后，libevent仍然能够处理连接关闭的事件。 整个Memcached网络模型确保了高并发和低延迟，主线程负责接收新连接，工作线程处理已有连接，充分利用多核处理器的能力，提高了服务性能。通过管道和连接队列，主线程和工作线程间实现了无锁通信，减少了同步开销。每个工作线程独立的libevent实例保证了线程间的隔离，避免了竞态条件，从而提高了系统的稳定性和效率。