MySQL数据库线程缓冲池详解

MySQL数据库线程缓冲池的相关知识是本文我们主要要介绍的内容，MySQL数据库支持线程缓存，在多线程连接模式下，如果连接断开后，将这个线程放入空闲线程缓冲区，在下次有连接到来时，先去缓冲池中查找是否有空闲线程，有则用之，无则创建。启动时可以设置线程缓冲池的数目：Mysqld.exe --thread_cache_size=10。

创新互联公司专注为客户提供全方位的互联网综合服务，包含不限于成都做网站、网站制作、兴庆网络推广、成都微信小程序、兴庆网络营销、兴庆企业策划、兴庆品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等，从售前售中售后，我们都将竭诚为您服务，您的肯定，是我们最大的嘉奖；创新互联公司为所有大学生创业者提供兴庆建站搭建服务，24小时服务热线：18982081108，官方网址：www.cdcxhl.com

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

 
 
 
      
  
  
  1. static bool cache_thread()  
    2.   
  
  
  2. {  
    3.   
  
  
  3. safe_mutex_assert_owner(&LOCK_thread_count);  
    4.   
  
  
  4. if (  
    5.   
  
  
  5. cached_thread_count < thread_cache_size 
    6.   
  
  
  6. &&  
    7.   
  
  
  7. ! abort_loop && !kill_cached_threads)  
    8.   
  
  
  8. {  
    9.   
  
  
  9. /* Don't kill the thread, just put it in cache for reuse */  
    10.   
  
  
  10. DBUG_PRINT("info", ("Adding thread to cache"));  
    11.   
  
  
  11. cached_thread_count++;  
    12.   
  
  
  12. while (!abort_loop && ! wake_thread && ! kill_cached_threads)  
    13.   
  
  
  13. (void) pthread_cond_wait(&COND_thread_cache, &LOCK_thread_count);  
    14.   
  
  
  14. cached_thread_count--;  
    15.   
  
  
  15. if (kill_cached_threads)  
    16.   
  
  
  16. pthread_cond_signal(&COND_flush_thread_cache);  
    17.   
  
  
  17. if (wake_thread)  
    18.   
  
  
  18. {  
    19.   
  
  
  19. THD *thd;  
    20.   
  
  
  20. wake_thread--;  
    21.   
  
  
  21. thd= thread_cache.get();  
    22.   
  
  
  22. thd->thread_stack= (char*) &thd;          // For store_globals  
    23.   
  
  
  23. (void) thd->store_globals();  
    24.   
  
  
  24. /*  
    25.   
  
  
  25. THD::mysys_var::abort is associated with physical thread rather  
    26.   
  
  
  26. than with THD object. So we need to reset this flag before using  
    27.   
  
  
  27. this thread for handling of new THD object/connection.  
    28.   
  
  
  28. */  
    29.   
  
  
  29. thd->mysys_var->abort= 0;  
    30.   
  
  
  30. thd->thr_create_utime= my_micro_time();  
    31.   
  
  
  31. threads.append(thd);  
    32.   
  
  
  32. return(1);  
    33.   
  
  
  33. }  
    34.   
  
  
  34. }  
    35.   
  
  
  35. return(0);  
    36.   
  
  
  36. } 
    37.

上面我们的启动参数设置线程缓冲区为10，此时对应代码里面的thread_cache_size = 10，cached_thread_count记录

了此刻cache中的空闲线程数目，只有在cache未满的情况下，才会将新的空闲线程加入缓冲池中。加入到缓冲区其实就是将线

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

如下：

 
 
 
      
  
  
  1. int pthread_cond_timedwait(pthread_cond_t *cond, pthread_mutex_t *mutex,  
    2.   
  
  
  2. struct timespec *abstime)  
    3.   
  
  
  3. int result;  
    4.   
  
  
  4. long timeout;   
    5.   
  
  
  5. union ft64 now;  
    6.   
  
  
  6. if( abstime != NULL )  
    7.   
  
  
  7. {  
    8.   
  
  
  8. GetSystemTimeAsFileTime(&now.ft);  
    9.   
  
  
  9. /*  
    10.   
  
  
  10. Calculate time left to abstime  
    11.   
  
  
  11. - subtract start time from current time(values are in 100ns units)  
    12.   
  
  
  12. - convert to millisec by dividing with 10000  
    13.   
  
  
  13. */  
    14.   
  
  
  14. timeout= (long)((abstime->tv.i64 - now.i64) / 10000);  
    15.   
  
  
  15. /* Don't allow the timeout to be negative */  
    16.   
  
  
  16. if (timeout < 0)  
    17.   
  
  
  17. timeout= 0L;  
    18.   
  
  
  18. /*  
    19.   
  
  
  19. Make sure the calucated timeout does not exceed original timeout  
    20.   
  
  
  20. value which could cause "wait for ever" if system time changes  
    21.   
  
  
  21. */  
    22.   
  
  
  22. if (timeout > abstime->max_timeout_msec)  
    23.   
  
  
  23. timeout= abstime->max_timeout_msec;  
    24.   
  
  
  24. }  
    25.   
  
  
  25. else  
    26.   
  
  
  26. {  
    27.   
  
  
  27. /* No time specified; don't expire */  
    28.   
  
  
  28. timeout= INFINITE;  
    29.   
  
  
  29. }  
    30.   
  
  
  30. /*   
    31.   
  
  
  31. Block access if previous broadcast hasn't finished.  
    32.   
  
  
  32. This is just for safety and should normally not  
    33.   
  
  
  33. affect the total time spent in this function.  
    34.   
  
  
  34. */  
    35.   
  
  
  35. WaitForSingleObject(cond->broadcast_block_event, INFINITE);  
    36.   
  
  
  36. EnterCriticalSection(&cond->lock_waiting);  
    37.   
  
  
  37. cond->waiting++;  
    38.   
  
  
  38. LeaveCriticalSection(&cond->lock_waiting);  
    39.   
  
  
  39. LeaveCriticalSection(mutex);  
    40.   
  
  
  40. result= WaitForMultipleObjects(2, cond->events, FALSE, timeout);  
    41.   
  
  
  41. EnterCriticalSection(&cond->lock_waiting);  
    42.   
  
  
  42. cond->waiting--;  
    43.   
  
  
  43. if (cond->waiting == 0)  
    44.   
  
  
  44. {  
    45.   
  
  
  45. /*  
    46.   
  
  
  46. We're the last waiter to be notified or to stop waiting, so  
    47.   
  
  
  47. reset the manual event.   
    48.   
  
  
  48. */  
    49.   
  
  
  49. /* Close broadcast gate */  
    50.   
  
  
  50. ResetEvent(cond->events[BROADCAST]);  
    51.   
  
  
  51. /* Open block gate */  
    52.   
  
  
  52. SetEvent(cond->broadcast_block_event);  
    53.   
  
  
  53. }  
    54.   
  
  
  54. LeaveCriticalSection(&cond->lock_waiting);  
    55.   
  
  
  55. EnterCriticalSection(mutex);  
    56.   
  
  
  56. return result == WAIT_TIMEOUT ? ETIMEDOUT : 0;  
    57.   
  
  
  57. } 
    58.

此处是等待时间，何处进行事件通知呢？我们再次来到上篇所提及的为新的连接创建线程的代码中：

 
 
 
      
  
  
  1. void create_thread_to_handle_connection(THD *thd)  
    2.   
  
  
  2. {  
    3.   
  
  
  3. if (cached_thread_count > wake_thread)  
    4.   
  
  
  4. {  
    5.   
  
  
  5. /* Get thread from cache */  
    6.   
  
  
  6. thread_cache.append(thd);  
    7.   
  
  
  7. wake_thread++;  
    8.   
  
  
  8. pthread_cond_signal(&COND_thread_cache);  
    9.   
  
  
  9. }  
    10.   
  
  
  10. Else  
    11.   
  
  
  11. ...  
    12.   
  
  
  12. } 
    13.

关于MySQL数据库线程缓冲池的相关知识就介绍到这里了，希望本次的介绍能够对您有所收获！

【编辑推荐】

  1. 如何检查MySQL数据库的主从延时？
  2. MySQL数据库时间类型的物理存储
  3. Linux cron执行MySQL失败的问题解决方案
  4. PHP与MySQL数据库中排序的对比及使用条件详解
  5. MySQL性能优化之使用Limit关键字来避免全表扫描

本文题目：MySQL数据库线程缓冲池详解
当前URL：http://www.shufengxianlan.com/qtweb/news42/490342.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

移动网站建设知识

同城分类信息

西部信息中心　　 　成都网站建设　　 　定制网站设计　　 　快照排名　　 　响应式网站设计方案　　 　成都网站制作　　 　边坡柔性防护网　　 　复盛机电设备　　 　做网站设计　　 　网站建设公司　　 　移动APP　　 　门户网站建设方案　　 　光华村机房　　 　网站建设　　 　四川柴油发电机　　 　成都主机托管　　 　成都网络营销公司　　 　成都富士康招工　　 　重庆网站建设网络公司　　 　温江服务器租用