基于redis-7.0.11源码(从中心的圆环-循环看起)
1、开启多线程功能需要配置两个选项:
对应源码中的变量:
server.io_threads_do_reads
server.io_threads_num
createBoolConfig("io-threads-do-reads", NULL, DEBUG_CONFIG | IMMUTABLE_CONFIG, server.io_threads_do_reads, 0,NULL, NULL), /* Read + parse from threads? */
createIntConfig("io-threads", NULL, DEBUG_CONFIG | IMMUTABLE_CONFIG, 1, 128, server.io_threads_num, 1, INTEGER_CONFIG, NULL, NULL), /* Single threaded by default */
2、在beforesleep阶段,会根据写数据的client的积压量来启用多线程模式
3、时间事件处理阶段processTimeEvents,也会根据写数据的client的积压量来关闭多线程模式。(多线程模式的是否启用主要依据积压的写数据的client量来决定,积压量超过或等于server.io_threads_num*2 才会开启多线程模式)。
4、多线程模式下,网络读会多线程读取网络数据到缓存,每个client由线程池中的一个线程负责,并尝试解析命令,单线程执行命令,并将返回的数据写到client的写缓存里。
5、写数据时,多线程模式把client里的写缓存写到网络中,每个client由线程池中的一个线程负责。
6、每次写入网络的数据有字节数有限制,如果没写完,会注册写事件,下次事件循环再继续写,这里继续写入并不是多线程模式(步骤4中的写事件处理)。
7、命令的执行是单线程,大key大value会阻塞,所以必须注意对性能的影响。
个人认为redis的多线程模式还没有那么完善,尤其是写入网络数据被限制大小后,会注册写事件,下次事件循环不以多线程模式写。