码迷,mamicode.com
首页 > 其他好文 > 详细

Percona 8.0 ThreadPool源码解析

时间:2020-04-03 18:26:24      阅读:62      评论:0      收藏:0      [点我收藏+]

标签:cti   方法   git   hub   内容   基本功   决定   RoCE   逻辑   

ThreadPool的基本功能在Percona 8.0里面没有太大的变化,只不调用的方式有变化,这里只介绍threadpool插件的初始化过程和调用过程。

threadpool本身的逻辑可以参考:

MariaDB · 源码分析 · thread pool

Percona 5.7线程池源码分析

threadpool插件初始化过

线程池默认是关闭的,要开启这个功能,需要启动实例时指定参数--thread-handling=pool-of-threads。这个参数在代码中对应的变量是Connection_handler_manager::thread_handling,其中Connection_handler_manager是一个singleton类,thread_handling是其静态成员变量。Connection_handler_manager是代码中连接模型的抽象,当实例启动后,会有一条线程专门监听指定的TCP端口和Unix Socket上是否有新的连接请求,这部分代码实现在mysqld_main --> Connection_acceptor->connection_event_loop()中,当有连接请求时会调用Connection_handler_manager中相应Connection_handler对象的add_connection()虚方法处理连接,线程池和之前的thread-per-connection模型在这里就会进入不同的代码路径,因为启用线程池时,Connection_handler_manager::handler为Thread_pool_connection_handler对象,而thread-per-connection模型时该成员为Per_thread_connection_handler对象。Connection_handler_manager::handler的确定是在函数Connection_handler_manager::init中,根据Connection_handler_manager::thread_handling决定构造哪个类的对象。

Connection_handler_manager::init()
{
  switch (Connection_handler_manager::thread_handling)
  {
  case SCHEDULER_ONE_THREAD_PER_CONNECTION:
    connection_handler= new (std::nothrow) Per_thread_connection_handler();
    break;
  case SCHEDULER_NO_THREADS:
    connection_handler= new (std::nothrow) One_thread_connection_handler();
    break;
  case SCHEDULER_THREAD_POOL:
    connection_handler= new (std::nothrow) Thread_pool_connection_handler();
    break;
  default:
    DBUG_ASSERT(false);
  }
}
mysqld_main
 ->init_server_components
  ->plugin_register_dynamic_and_init_all
   ->plugin_init_initialize_and_reap
    ->plugin_initialize
     ->threadpool_plugin_init
	    tp_init  # 初始化threadpool
	    my_connection_handler_set  # 设置connection_handler
		 Plugin_connection_handler *conn_handler = new (std::nothrow) Plugin_connection_handler(chf);
		 Connection_handler_manager::get_instance()->load_connection_handler(conn_handler);

其中tp_init是初始化threadpool的核心入口,初始化 thread_group_t 数组。

my_connection_handler_set设置连接的处理模式。

threadpool调用过程

mysqld_main
 ->connection_event_loop
  ->Connection_handler_manager::process_new_connection
   ->add_connection

其中add_connection就是threadpool的核心入口,主要内容如下:

创建connection,将connection分配到一个thread_group,插入group队列。

唤醒或创建一个worker thread,如果group中没有活跃的worker thread。

Percona 8.0 ThreadPool源码解析

标签:cti   方法   git   hub   内容   基本功   决定   RoCE   逻辑   

原文地址:https://www.cnblogs.com/jmliao/p/12627860.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!