关于线程池ThreadPoolExecutor的深度思考

落日映苍穹つ 2022-02-17 03:42 156阅读 0赞

今天，又一次梳理了下关于线程池ThreadPoolExecutor的运行原理，重新阅读源码，又一次加深理解。

在梳理ThreadPoolExecutor运行原理前，问了自己几个问题：

（1）task什么时候执行，如何执行？

（2）当thread数<core size时，task执行完后，thread又如何保持运行中，而不被销毁？

（3）当task个数>core size && task个数 < max size时， thread如何超时timeout而被销毁？

首先，重新阅读源码，并重新绘制新理解的脑图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1bmN0_size_16_color_FFFFFF_t_70][]

当task执行/提交后，task包装成worker，worker中具有私有thread

（1）当线程池中的正执行thread个数<CoreSize时，添加到workers中，并直接执行start，**开始循环从2个渠道获取task**。

获取task有2个渠道：本身的task、等待队列workerQueue中task对象（使用阻塞方式take获取任务）

其中**使用阻塞task方法从等待队列workerQueue中获取任务**，如果没有任务，则thread一直阻塞，前提allowCoreThreadTimeout==false。

如果allowCoreThreadTimeout==true，则线程池使用第（2）种方式 执行。

（2）当线程池中的正执行thread个数>CoreSize && 正执行thread个数<MaxSize && 等待队列workerQueue已满时，task直接添加到workers中，并直接执行start，开始循环获取task。

获取task有2个渠道：本身的task、等待队列workerQueue中task对象（使用非阻塞方式poll获取任务）

其中**使用具有超时keepAliveTime的非阻塞方式poll从等待队列workerQueue中获取任务**，如果没有任务，则thread执行完成，自动销毁。

一直到线程池中thread个数<=CoreSize，则线程池回到第（1）种方式执行。

**总结：**

（1）task什么时候执行，如何执行？

task提交后，自动创建thread，并执行task，同时**循环**从等待队列中获取任务，

（2）当thread数<core size时，task执行完后，thread又如何保持运行中，而不被销毁？

thead以阻塞方式take从阻塞等待队列中获取，如果没有任务，则thread一直阻塞，而不会执行完毕，不被销毁

（3）当task个数>core size && task个数 < max size时， thread如何超时timeout而被销毁？

thead以具有超时keepAliveTime的非阻塞方式poll从等待队列中获取，如果没有任务，则thread执行完毕，从而被销毁

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3N1bmN0_size_16_color_FFFFFF_t_70]: /images/20220217/58c79ae8aea24291973c0e7827a006eb.png

发表评论取消回复

表情：

评论列表（有 0 条评论，156人围观）

还没有评论，来说两句吧...

相关阅读

相关线程池-ThreadPoolExecutor

以下为构造线程池实例的构造方法： ![20201006131137786.png][] corePoolSize:核心线程数量 maximumPoolSiz

野性酷女/ 2022年12月12日 04:52/ 0 赞/ 248 阅读

相关线程池（二）：ThreadPoolExecutor

> 这次做笔记，学乖了！线程池的状态 ThreadPoolExectuor 使用 int 的高 3 位来表示线程池的状态，低 29 为表示线程数量。 <table>

女爷i/ 2022年10月16日 00:57/ 0 赞/ 170 阅读

相关线程池---ThreadPoolExecutor

ThreadPoolExecutor 个人对线程池的理解：参数--- corePoolSize-----线程池维护线程的最少数量 maximumPoolSize--线

素颜马尾好姑娘i/ 2022年07月14日 13:59/ 0 赞/ 265 阅读

相关 java 线程池ThreadPoolExecutor

1. ThreadPoolExecutor的一个常用的构造方法 ThreadPoolExecutor(int corePoolSize, int maximumP

忘是亡心i/ 2022年06月15日 05:49/ 0 赞/ 228 阅读

相关 java线程池ThreadPoolExecutor

部分内容借鉴别的文章 package com.xhx.java; import static org.junit.Assert.assert

小鱼儿/ 2022年05月24日 09:53/ 0 赞/ 277 阅读

相关线程池ThreadPoolExecutor

构造方法： ThreadPoolExecutor executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSi

水深无声/ 2022年05月23日 07:46/ 0 赞/ 249 阅读

相关 ThreadPoolExecutor线程池

package com.hzcard.crm; import java.util.concurrent.; publi

红太狼/ 2022年04月24日 11:46/ 0 赞/ 285 阅读

相关线程池ThreadPoolExecutor

> 主要流程如下，如果看懂了，那么这篇就可以跳过了。 ![image][] 图片来源：[https://www.cnblogs.com/KingJack/p/959562

系统管理员/ 2022年03月19日 02:58/ 0 赞/ 398 阅读

相关 ThreadPoolExecutor线程池

ThreadPoolExecutor线程池昨天去百趣网面试，面试官问了很多问题，其中有部分是关于线程池的。因为只是用过，但是对其中的原理和应用场景还是一知半解，痛定

待我称王封你为后i/ 2022年02月17日 15:40/ 0 赞/ 331 阅读

相关关于线程池ThreadPoolExecutor的深度思考

今天，又一次梳理了下关于线程池ThreadPoolExecutor的运行原理，重新阅读源码，又一次加深理解。在梳理ThreadPoolExecutor运行原理前，问了自己几

落日映苍穹つ/ 2022年02月17日 03:42/ 0 赞/ 157 阅读