面试官：说一下线程池内部工作原理？

今天药忘吃喽~ 2023-01-23 09:47 230阅读 0赞

![0f0602f42db95833d5b70fcf64b2a3a2.png][]

随着cpu核数越来越多，不可避免的利用多线程技术以充分利用其计算能力。所以，多线程技术是服务端开发人员必须掌握的技术。

线程的创建和销毁，都涉及到系统调用，比较消耗系统资源，所以就引入了线程池技术，避免频繁的线程创建和销毁。

在Java中有一个Executors工具类，可以为我们创建一个线程池，其本质就是new了一个ThreadPoolExecutor对象。线程池几乎也是面试必考问题。本节结合源代码，说说ThreadExecutor的工作原理

## 一、线程池创建 ##

先看一下ThreadPoolExecutor参数最全的构造方法：

![e4cbb0a534fc5b91d9672f2bcf027238.png][] 图片

*  **corePoolSize：** 线程池的核心线程数，说白了就是，即便是线程池里没有任何任务，也会有corePoolSize个线程在候着等任务。
 *  **maximumPoolSize：** 最大线程数，不管你提交多少任务，线程池里最多工作线程数就是maximumPoolSize。
 *  **keepAliveTime：** 线程的存活时间。当线程池里的线程数大于corePoolSize时，如果等了keepAliveTime时长还没有任务可执行，则线程退出。
 *  **unit：** 这个用来指定keepAliveTime的单位，比如秒:TimeUnit.SECONDS。
 *  **workQueue：** 一个阻塞队列，提交的任务将会被放到这个队列里。
 *  **threadFactory：** 线程工厂，用来创建线程，主要是为了给线程起名字，默认工厂的线程名字：pool-1-thread-3。
 *  **handler：** 拒绝策略，当线程池里线程被耗尽，且队列也满了的时候会调用。

以上就是创建线程池时用到的参数，面试中经常会有面试官问到这个问题。

## 二、线程池执行流程 ##

这里用一个图来说明线程池的执行流程

![fdbec2e66e4c1d29746f609436bac876.png][] 图片

任务被提交到线程池，会先判断当前线程数量是否小于corePoolSize，如果小于则创建线程来执行提交的任务，否则将任务放入workQueue队列，如果workQueue满了，则判断当前线程数量是否小于maximumPoolSize,如果小于则创建线程执行任务，否则就会调用handler，以表示线程池拒绝接收任务。

这里以jdk1.8.0\_111的源代码为例，看一下具体实现。

### 1、先看一下线程池的executor方法 ###

![fe1769732ba82acf21592465f2974146.png][] 图片

*  判断当前活跃线程数是否小于corePoolSize,如果小于，则调用addWorker创建线程执行任务
 *  如果不小于corePoolSize，则将任务添加到workQueue队列。
 *  如果放入workQueue失败，则创建线程执行任务，如果这时创建线程失败(当前线程数不小于maximumPoolSize时)，就会调用reject(内部调用handler)拒绝接受任务。

### 2、再看下addWorker的方法实现 ###

这块代码是在创建非核心线程时，即core等于false。判断当前线程数是否大于等于maximumPoolSize，如果大于等于则返回false，即上边说到的③中创建线程失败的情况。

addWorker方法的下半部分：

![114244ff616e0bdaf5dcffa7f3604e9f.png][] 图片

*  创建Worker对象，同时也会实例化一个Thread对象。
 *  启动启动这个线程

### 3、再到Worker里看看其实现 ###

![ecc2dd70e2c9f6c30a75d668309534be.png][] 图片

可以看到在创建Worker时会调用threadFactory来创建一个线程。上边的②中启动一个线程就会触发Worker的run方法被线程调用。

### 4、接下来咱们看看runWorker方法的逻辑 ###

![1940dc844dee26e5057b2b284940e8e9.png][] 图片

线程调用runWoker，会while循环调用getTask方法从workerQueue里读取任务，然后执行任务。只要getTask方法不返回null,此线程就不会退出。

### 5、最后在看看getTask方法实现 ###

![7e2cd78745090907d1348c60a1d722af.png][] 图片

*  咱们先不管allowCoreThreadTimeOut，这个变量默认值是false。wc>corePoolSize则是判断当前线程数是否大于corePoolSize。
 *  如果当前线程数大于corePoolSize，则会调用workQueue的poll方法获取任务，超时时间是keepAliveTime。如果超过keepAliveTime时长，poll返回了null，上边提到的while循序就会退出，线程也就执行完了。

如果当前线程数小于corePoolSize，则会调用workQueue的take方法阻塞在当前。

往期推荐

[产品需求：用java做一个长链接转短链的微服务][java]

[【elasticsearch】数据早8小时or晚8小时，你知道为什么吗？附解决方案][elasticsearch_8_or_8]

[java项目，这样优雅的处理 Exception 实践，客户都给你点赞][java_ Exception]

[大实话：等电梯的时候，90%的程序员都想过调度算法][90]

[SpringBoot实现API接口多版本支持][SpringBoot_API]

[太多项目使用MyBatis，你理解它的架构和原理吗？][MyBatis]

[干了这么些年程序员，这7种软件架构模式必须得掌握了][7]

[前端入门攻略，高效！][Link 1]

**若觉得文章对你有帮助，****随手转发分享，也是侠梦继续更新的动力。**

![e1c70bf9984d2aee69c3cfab88a69475.gif][]

![94742c4dea27c219dd9d280c88f6b69f.png][]

![fab90f2278d4fdbe6d995227d4b48915.gif][]

[0f0602f42db95833d5b70fcf64b2a3a2.png]: /images/20221004/b5410492159548179defa26c1ab6ec22.png
[e4cbb0a534fc5b91d9672f2bcf027238.png]: /images/20221004/4b3b649bf7d24504aae9f5a1c55f49d8.png
[fdbec2e66e4c1d29746f609436bac876.png]: /images/20221004/ea3259709de94d739d12dc779c740a8d.png
[fe1769732ba82acf21592465f2974146.png]: /images/20221004/3d7df681171e48758dcaf400c73a39ed.png
[114244ff616e0bdaf5dcffa7f3604e9f.png]: /images/20221004/99a0b870acd8441c8bdfa50756cb6fb9.png
[ecc2dd70e2c9f6c30a75d668309534be.png]: /images/20221004/9e082738c90f43f2a1cc25f0fe7eaa9c.png
[1940dc844dee26e5057b2b284940e8e9.png]: /images/20221004/e22c5f32a77f41cf98c71e2f085eb549.png
[7e2cd78745090907d1348c60a1d722af.png]: /images/20221004/599bd08df69b49daba33ede9f1cb7611.png
[java]: http://mp.weixin.qq.com/s?__biz=MzU2NDc4MjE2Ng%3D%3D&chksm=fc44ec4ecb336558c4ab1ea71982984ca0935fa355b23707e2dbbf38e48b88ea29d0387f8195&idx=1&mid=2247489911&scene=21&sn=fd587cc24b56b4c79431c6efe3ee64c3#wechat_redirect
[elasticsearch_8_or_8]: http://mp.weixin.qq.com/s?__biz=MzU2NDc4MjE2Ng%3D%3D&chksm=fc44ec4ecb3365583d1edd3cf070cedbc443439b0fce6a6ef70b25169fad51dbb3385edb7444&idx=2&mid=2247489911&scene=21&sn=b22411aea5b6f4660e200d6f53f7b467#wechat_redirect
[java_ Exception]: http://mp.weixin.qq.com/s?__biz=MzU2NDc4MjE2Ng%3D%3D&chksm=fc44ec73cb3365658ea7013c5e2c0e35fb8acc9d03b7b43c5015bcab1c4b467d87e6eaebac7e&idx=1&mid=2247489866&scene=21&sn=0a45b43ef5c24ec3ce852e973bef1c59#wechat_redirect
[90]: http://mp.weixin.qq.com/s?__biz=MzU2NDc4MjE2Ng%3D%3D&chksm=fc44ec7bcb33656d274611e70048cfba05ae34ae2382d84aae01e9fcdfb30a1e4dad7bcd5153&idx=2&mid=2247489858&scene=21&sn=5a2bf75e333fba2d67bb4a043d421088#wechat_redirect
[SpringBoot_API]: http://mp.weixin.qq.com/s?__biz=MzU2NDc4MjE2Ng%3D%3D&chksm=fc44ec2acb33653c3fda67373cddeba16cb07c7baf87d3e879a494e486f3a4eacb74ba68a3e8&idx=1&mid=2247489811&scene=21&sn=6029b7b8d82753efa260d0c7ee093a3d#wechat_redirect
[MyBatis]: http://mp.weixin.qq.com/s?__biz=MzU2NDc4MjE2Ng%3D%3D&chksm=fc44ec36cb3365201cf9fdaaf57be38c72de39612cc07b9f2de2eeb1e9c13512140b9ffe01c1&idx=1&mid=2247489807&scene=21&sn=11a0903158c30553a8d4ee7664ff13c7#wechat_redirect
[7]: http://mp.weixin.qq.com/s?__biz=MzU2NDc4MjE2Ng%3D%3D&chksm=fc44ec34cb33652220f4c5d538936efcc00c1d6e3d1033023026c6a30ac32b0adaa1cd721493&idx=1&mid=2247489805&scene=21&sn=22ea9c5be2461e34a1fc7ed3437b3045#wechat_redirect
[Link 1]: http://mp.weixin.qq.com/s?__biz=MzU2NDc4MjE2Ng%3D%3D&chksm=fc44ec32cb336524509d81b999c99419da4683862842297436aca7572bc39f76bc2265df061e&idx=1&mid=2247489803&scene=21&sn=89b05314da4c54b9d1d5d7b15480de0e#wechat_redirect
[e1c70bf9984d2aee69c3cfab88a69475.gif]: /images/20221004/91891fdb57d64a70b2d475e26cc24a09.png
[94742c4dea27c219dd9d280c88f6b69f.png]: /images/20221004/a37336dd35844fc2ab53e3cc3cb3b77f.png
[fab90f2278d4fdbe6d995227d4b48915.gif]: /images/20221004/5b90896048a44b8aa8a183127279a8d8.png