通俗易懂，常用线程池执行的-流程图

搜云库技术团队关注送4000G架构师视频

有时候花了大把时间去看一些东西却看不懂，是很 “ 蓝瘦 ” 的，花时间也是投资。

本文适合：

曾了解过线程池却一直模模糊糊的人 了解得差不多却对某些点依然疑惑的

不适合：

完全没看过的，建议你先去看看其他基础文章 看过，却忘得差不多了，建议你先去回顾下

本文能给你的阅读回报

适合的读者，尽可能让你彻底明白 常用的线程池的知识相关点 不适合的读者，能有个不错的概念，神童另谈

---

废话少说，我们开始。

默认构造函数

1. public ThreadPoolExecutor(

2.    int corePoolSize,

3.    int maximumPoolSize,

4.    long keepAliveTime,

5.    TimeUnit unit,

6.    BlockingQueue<Runnable> workQueue,

7.    ThreadFactory threadFactory,

8.    RejectedExecutionHandler handler

9. )

10. {

11.    ....

12. }

13. 复制代码

绝对易懂的构造方法参数讲解

corePoolSize，maximumPoolSize，workQueue之间关系。

文字描述

1、当线程池中线程数小于corePoolSize时，新提交任务将创建一个新线程执行任务，即使此时线程池中存在空闲线程。

2、当线程池中线程数达到corePoolSize时，新提交任务将被放入workQueue中，等待线程池中任务调度执行 。

3、当workQueue已满，且maximumPoolSize > corePoolSize时，新提交任务会创建新线程执行任务。

4、当workQueue已满，且提交任务数超过maximumPoolSize，任务由RejectedExecutionHandler处理。

5、当线程池中线程数超过corePoolSize，且超过这部分的空闲时间达到keepAliveTime时，回收这些线程。

6、当设置 allowCoreThreadTimeOut(true)时，线程池中corePoolSize范围内的线程空闲时间达到keepAliveTime也将回收。

一般流程图

newFixedThreadPool 流程图

1. public static ExecutorService newFixedThreadPool(int nThreads){

2.    return new ThreadPoolExecutor(

3.            nThreads,   // corePoolSize

4.            nThreads,   // maximumPoolSize == corePoolSize

5.            0L,         // 空闲时间限制是 0

6.            TimeUnit.MILLISECONDS,

7.            new LinkedBlockingQueue<Runnable>() // 无界阻塞队列

8.        );

9. }

newCacheThreadPool 流程图

1. public static ExecutorService newCachedThreadPool(){

2.    return new ThreadPoolExecutor(

3.        0,                  // corePoolSoze == 0

4.        Integer.MAX_VALUE,  // maximumPoolSize 非常大

5.        60L,                // 空闲判定是60 秒

6.        TimeUnit.SECONDS,

7.        // 神奇的无存储空间阻塞队列，每个 put 必须要等待一个 take

8.        new SynchronousQueue<Runnable>()  

9.    );

10. }

newSingleThreadPool 流程图

1. public static ExecutorService newSingleThreadExecutor() {

2.        return

3.            new FinalizableDelegatedExecutorService

4.                (

5.                    new ThreadPoolExecutor

6.                        (

7.                            1,

8.                            1,

9.                            0L,

10.                            TimeUnit.MILLISECONDS,

11.                            new LinkedBlockingQueue<Runnable>(),

12.                            threadFactory

13.                        )

14.                );

15.    }

16. 复制代码

可以看到除了多了个 FinalizableDelegatedExecutorService 代理，其初始化和 newFiexdThreadPool 的 nThreads = 1 的时候是一样的。 区别就在于：

1、newSingleThreadExecutor返回的ExcutorService在析构函数finalize()处会调用shutdown() 2、如果我们没有对它调用shutdown()，那么可以确保它在被回收时调用shutdown()来终止线程。

使用 ThreadFactory，可以改变线程的名称、线程组、优先级、守护进程状态，一般采用默认。

流程图略，请参考 newFiexdThreadPool，这里不再累赘。

最后

还有一个定时任务线程池 ScheduledThreadPool

它用来处理延时或定时任务，不常用

原文：

juejin.im/post/5a28b37c6fb9a044fc44a103

干货文章转发起来，让大家一起学习

更多技术干货

阅读原文可获得4000G架构师视频