Mysql源码学习——Thread Manager

  • 时间:
  • 浏览:1

    timeout= (long)((abstime->tv.i64 - now.i64) / 111500);

           ("Can't create thread to handle request (error %d)",error));

}

  if (wake_thread)

int pthread_cond_timedwait(pthread_cond_t *cond, pthread_mutex_t *mutex,

srv_lock_timeout_thread

pthread_create创建的线程池池

  DBUG_RETURN(0);

  {

           pthread_handler func, void *param)

handle_connections_sockets

recv_recovery_from_checkpoint_finish

func=((struct pthread_map *) param)->func

  VOID(SetThreadPriority(hThread, attr->priority)) ;

  LeaveCriticalSection(mutex);

  return result == WAIT_TIMEOUT ? ETIMEDOUT : 0;

    threads.append(thd);

  win_pthread_self=((struct pthread_map *) param)->pthreadself;

  {

  pthread_handler

  *thread_id=map->pthreadself=hThread;

  EnterCriticalSection(mutex);

#else

二、基本概念

srv_monitor_thread

    SetEvent(cond->broadcast_block_event);

map->func=func; map->param=param;

handle_connections_methods

  if (cached_thread_count > wake_thread)

    os_thread_create是存储引擎innobase的线程池池函数,先搁浅不研究了,重点看下pthread_create,首先看下其源码。

trx_rollback_or_clean_all_without_sess

   通过在两个 创建线程池池的地方设置断点,总结了下,在服务器启动时,创建了如下的线程池池。

    thd->mysys_var->abort= 0;

程挂起,pthread_cond_wait函数便是线程池池等待英文函数,在此函数中,会调用WaitForMultipleObjects进行事件等待英文。具体源码

}

      timeout= 0L;

  EnterCriticalSection(&cond->lock_waiting);

Mysqld.exe --thread_cache_size=10

   cached_thread_count++;

    thd->thread_stack= (char*) &thd;         

  return 0;              

  if (cond->waiting == 0)

        Mysql支持线程池池缓存,在线程池池池连接模式下,机会连接断开后,将这种线程池池插进空闲线程池池缓冲区,在下次有连接到来时,

  long timeout;

 {

如下:

  pthread_mutex_lock(&THR_LOCK_thread);  

  if( abstime != NULL )

    上篇的Connection Manager中,曾提及对于两个 新到来的Connection,服务器会创建两个 新的线程池池来出理 这种连接。

     ! abort_loop && !kill_cached_threads)

int pthread_create(pthread_t *thread_id, pthread_attr_t *attr,

{

start_handle_manager

{

hThread=(HANDLE)_beginthread((void( __cdecl *)(void *)) pthread_start, attr->dwStackSize ? attr->dwStackSize : 65535, (void*) map);

    if (timeout < 0)

   while (!abort_loop && ! wake_thread && ! kill_cached_threads)

  pthread_mutex_lock(&THR_LOCK_thread);

cached_thread_count < thread_cache_size

   DBUG_PRINT("info", ("Adding thread to cache"));

    thd->thr_create_utime= my_micro_time();

线程池池,机会cache中的总数>被重新使用的数目,说明还有空闲的线程池池,此时进入if分支,调用phtread_cond_signal唤醒顶端挂起

;

return(0);

    thread_cache.append(thd);

      在两个 连接断开时,会调用cache_thread函数,将空闲的线程池池加入到cache中,以备后用。源码如下:

   if (kill_cached_threads)

srv_master_thread

pthread_cond_signal(&COND_thread_cache);

虽然没不到 简单,为了提高系统传输波特率,减少频繁创建线程池池与生止线程池池的系统消耗,Mysql使用了线程池池缓冲区的概念,即机会

先去缓冲池中查找是与非 空闲线程池池,有则用之,无则创建。启动时能不到设置线程池池缓冲池的数目:

  void *func_param=((struct pthread_map *) param)->param;

  DBUG_PRINT("info", ("hThread=%lu",(long) hThread));

   2.服务器启动时创建了哪此函数?

#ifdef __BORLANDC__

    (void) thd->store_globals();

  safe_mutex_assert_owner(&LOCK_thread_count);

{

                           struct timespec *abstime)

    顶端亲戚亲戚朋友的启动参数设置线程池池缓冲区为10,此时对应代码顶端的thread_cache_size = 10,cached_thread_count记录

void create_thread_to_handle_connection(THD *thd)

  {

  int result;

    int error=errno;

{

的空闲线程池池。

  {

  HANDLE hThread;

总出 在主服务器框架外,存储引擎也机会会进行线程池池的创建。通过设置断点,在我调试的版本中,发现了两个 创建线程池池的函数。

  if (

innobase的os_thread_create创建的线程池池:

io_handler_thread(两个 )

    THD *thd;

    DBUG_RETURN(-1);

  }

  pthread_mutex_unlock(&THR_LOCK_thread);

  struct pthread_map *map;

    1.线程池池创建函数

  pthread_exit((void*) (*func)(func_param));

innobase_start_or_create_for_mysql

handle_shutdown

innobase_start_or_create_for_mysql

    DBUG_RETURN(error ? error : -1);

#endif

    还能不到在调试过程中,通过暂停来看此时服务器中的线程池池,如下图:

pthread_create:Mysql自用的创建线程池池函数

  LeaveCriticalSection(&cond->lock_waiting);

&&

三、线程池池缓冲池

                   attr->dwStackSize ? attr->dwStackSize :

    thd= thread_cache.get();

首先介绍下基本的概念。

  EnterCriticalSection(&cond->lock_waiting);

    wake_thread++;

顶端代码首先构造了两个 map形状体,成员分别是函数地址和传入参数。可是 调用操作系统的接口,_beginthread,可是 执行函数并全部都在传入的函数——func,假如有一天pthread_start,参数为map。继续跟踪pthread_start。

  else

两个 连接断开,则何必 销毁承载其的线程池池,假如有一天将此线程池池插进线程池池缓冲区,并存在挂起情况表,当下两个 新的Connection到来

    上篇文章亲戚亲戚朋友虽然只讲了ELSE分支,而忽略了IF分支。wake_thread代表了唤醒的线程池池数,即在线程池池缓冲区中被再次使用的

  pthread_mutex_unlock(&THR_LOCK_thread);

  }

  hThread=(HANDLE)_beginthread((void(_USERENTRY *)(void *)) pthread_start,

handle_manager

  cond->waiting++;

  free((char*) param);           

时,首先去线程池池缓冲区去查找是与非 空闲的线程池池,机会有,则使用之,机会不到 则新建线程池池。本问主要介绍这种线程池池缓冲区,

      timeout= abstime->max_timeout_msec;

pthread_cond_signal(&COND_flush_thread_cache);

create_shutdown_thread

   能不到看出,pthread_start中调用了map的func元素,作为真正执行的函数体。OK,创建线程池池的函数跟踪到此!

    timeout= INFINITE;

}

  {

线程池池管理就到此为止了,这里假如有一天介绍了下线程池池缓冲区的工作原理,并不到 具体去介绍怎么可不可以利用EVENT进行线程池池的挂起和唤醒,哪此全部都在借助了操作系统的形状,有兴趣的能不到此人 研究下。这篇就到此为止,下节会介绍Mysql的用户身份认证原理和实现。

    DBUG_PRINT("error",

  }

  union ft64 now;

  cond->waiting--;

  if (hThread == (HANDLE) -1)

    GetSystemTimeAsFileTime(&now.ft);

PS. 男怕入错行,夜半三更忙,一行又一行

  }

    return(1);

   cached_thread_count--;

  my_thread_init();        

  if (!(map=malloc(sizeof(*map))))

pthread_handler_t pthread_start(void *param)

}

  {

    if (timeout > abstime->max_timeout_msec)

  WaitForSingleObject(cond->broadcast_block_event, INFINITE);

    此处是等待英文时间,何处进行事件通知呢?亲戚亲戚朋友再次来到上篇所提及的为新的连接创建线程池池的代码中:

了此刻cache中的空闲线程池池数目,不到在cache未满的情况表下,才会将新的空闲线程池池加入缓冲池中。加入到缓冲区虽然假如有一天将线

srv_error_monitor_thread

一、前言

    wake_thread--;

{

  LeaveCriticalSection(&cond->lock_waiting);

    ResetEvent(cond->events[BROADCAST]);

                   65535, (void*) map);

  DBUG_ENTER("pthread_create");

result= WaitForMultipleObjects(2, cond->events, FALSE, timeout);

    亲戚亲戚朋友知道,Mysql现在是插件式的存储引擎,假如有一天实现规定的接口,就可实现此人 的存储引擎。故Mysql的线程池池创建除了

static bool cache_thread()

os_thread_create:存储引擎innobase的创建线程池池的函数

  }

     (void) pthread_cond_wait(&COND_thread_cache, &LOCK_thread_count);