文章目录
- 前提
- 动态减少
- 代码解读
- 动态增加
- 线程池退出时发生了什么?
- 总结
- 附录
前提
我们在关于Hipe并发库中动态线程库DynamicThreadPond的一点解读(一)中介绍了DynamicThreadPond如何初始化,如何向任务队列中添加任务,线程池中的线程如何执行任务队列中的任务等。
这一节我们来介绍动态线程池的动态,也就是如何动态增加或减少线程池中的线程。
注意:这里的动态可能和你想的动态不太一样,接下来慢慢看。
动态减少
删除线程池中的线程的示例代码如下:
代码的输出结果如下:
==========================================
* Test DynamicThreadPond *
==========================================
===========<[modify threads]>===========
thread-numb = 5
tasks-numb = 0
Wait for threads deleted ...
Get-Running-thread-numb-again = 0
Get-Expect-thread-numb-again = 0
===================================
* End of the test *
===================================
代码解读
如上所示的代码中,我们先起一个线程池,初始线程数为5,然后打印下正在运行的线程数以及任务队列中的任务数。接着向队列中添加5个任务,然后删除所有正在运行的线程。
第一个重点是:delThreads(int)
函数是怎么实现的?
第二个重点是:线程池中的线程接收到通知后做了什么?
用一句话描述就是:当线程池中的线程收到通知后,会转移资源的所有权,然后退出while循环。这样的话,线程池中的线程数量就会在减少。
第三个点是:waitForThreads()
函数在做什么?
waitForThreads()
就是主线程阻塞,等待线程池中的线程数调整到我们相要的数量。
最后一个重点是:删除的线程要回收资源,也就是要join
。
综上,这就是动态减少线程池中线程数的过程。
动态增加
动态增加线程池中的线程数的,就是使用在第一节中介绍的addThreads(int)
函数,如下
线程池退出时发生了什么?
线程池如何退出呢?是不是需要一个退出的接口?任务队列中的任务怎么处理?…,这些问题也值得我们关注。
代码中给我们提供了一个close
的公有接口,用来关闭线程池。
很好的一点是,这里还使用了RAII技术,就是说:就算不显式调用close()
,当线程池离开其生命周期时,在其析构函数中也会调用close
帮助我们释放资源。
总结
以上就是本节的所有内容。然后可以解释下开头的那句话:
这里的动态可能和你想的动态不太一样。
在我没有阅读代码之前,我一直以为动态减少的那些线程会保存起来,待需要动态增加时,再重新拿出来使用。阅读完代码后,才发现自己理解错了。减少的线程会被join
,增加线程时会重新创建线程。
附录
如果我们要动态改变线程数,不建议直接使用addThreads
和delThreads
这两个函数,同时这两个函数应该被声明为private
。
因为线程池给我们提供了一个动态调整的函数,如下所示: