​memcached 线程模型分析

	typedef struct {
		pthread_t thread_id;        /* 工作线程ID*/
		struct event_base *base;    /* libevent的句柄 */
		struct event notify_event;  /* listen event */
		int notify_receive_fd;      /* 客户端线程监听这个套接字接受来自服务端通知，比如新连接 */
		int notify_send_fd;         /* 主线程有消息，会往这个fd中进行写入数据 */
		struct thread_stats stats;  /* 线程的状态 */
		struct conn_queue *new_conn_queue; /* 该队列存储CQ_ITEM把服务端接受到的客户端fd状态为CQ_ITEM，放到这个队列中 */
		cache_t *resp_cache;        /* response objects */
		cache_t *rbuf_cache;        /* static-sized read buffers */
		cache_t *io_cache;          /* IO objects */
		void *storage;              /* data object for storage system */
		logger *l;                  /* logger buffer */
		void *lru_bump_buf;         /* async LRU bump buffer */
		char   *ssl_wbuf;
	} LIBEVENT_THREAD;

	//memcached的工作线程的初始化函数
	void memcached_thread_init(int nthreads, void *arg) {
	//每个工作线程的初始化
		threads = calloc(nthreads, sizeof(LIBEVENT_THREAD));
		if (! threads) {
	    perror("Can't allocate thread descriptors");
	    exit(1);
		}
	
		for (i = 0; i < nthreads; i++) {
	    	int fds[2];
	    	if (pipe(fds)) {
	        perror("Can't create notify pipe");
	        exit(1);
	    	}
	    //当有新连接时候，主线程会选择性的写数据到线程的notify_send_fd，然后工作线程在从notify_receive_fd读取数据，然后取出连接开始处理
			//工作线程从notify_receive_fd读取数据
	    threads[i].notify_receive_fd = fds[0];
		//主线程从notify_send_fd写入数据
	    threads[i].notify_send_fd = fds[1];
		//设置每个线程中event监听notify_receive_fd中的数据
	    setup_thread(&threads[i]);
	    /* Reserve three fds for the libevent base, and two for the pipe */
	    stats_state.reserved_fds += 5;
	}
	
	/* Create threads after we've done all the libevent setup. */
	//启动每个工作线程,每个线程执行event_base_loop
	for (i = 0; i < nthreads; i++) {
	    create_worker(worker_libevent, &threads[i]);
	}
}

//函数入口，在memcached的入口
main 
//初始化全局的conns,max_fds = settings.maxconns + headroom + next_fd;
conn_init();
//main线程的event初始化
main_base = event_init();
//和server_socket类型，不同的仅仅是制定网卡绑定
server_sockets 
	//main线程通过socket/bind/listen来初始化listen_conn，设置该连接的类型，listen_conn中的sfd放到main_base监听
	server_socket 
		//根据sfd初始化一个conn放到main_base中，设置回函数event_handler
		conn_new 
//初始化工作线程
memcached_thread_init 
	//设置工作线程，把notify_receive_fd放到工作线程的event_base中监听
	setup_thread 
		//设置notify_receive_fd中IO事件处理函数
		thread_libevent_process 
	//启动单独线程开始监听notify_receive_fd的IO时间
	worker_libevent 
event_base_loop
event_base_free

//针对main线程，把服务端的listenfd放到main_base中，针对工作线程则注册
event_handler notify_receive_fd注册到event_base中
	drive_machine //接受来自客户端IO请求，这是最重要的函数
		dispatch_conn_new //把请求的FD封装到CQ_ITEM中，然后放到工作线程的队列中，然后通知工作线程有新连接进去

1.main_base监听listenfd的IO事件，触发函数event_handler
2.工作线程中的base监听notify_receive_fd和客户端的fd,针对notify_receive_fd设置thread_libevent_process 函数；针对客户端的FD设置event_handler的回调函数