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

未分类 2年前 (2022) 程序员胖胖胖虎阿

337 0 0

点击上方
蓝色字体
，选择“标星公众号”

优质文章，第一时间送达

来自 | 林冠宏

链接 |

juejin.im/post/5a28b37c6fb9a044fc44a103

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

本文适合：

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

不适合：

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

本文能给你的阅读回报

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

废话少说，我们开始。

默认构造函数

public ThreadPoolExecutor(    int corePoolSize,    int maximumPoolSize,    long keepAliveTime,    TimeUnit unit,    BlockingQueue<Runnable> workQueue,    ThreadFactory threadFactory,    RejectedExecutionHandler handler) {    ....}

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

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 流程图

public static ExecutorService newFixedThreadPool(int nThreads){    return new ThreadPoolExecutor(            nThreads,   // corePoolSize            nThreads,   // maximumPoolSize == corePoolSize            0L,         // 空闲时间限制是 0            TimeUnit.MILLISECONDS,            new LinkedBlockingQueue<Runnable>() // 无界阻塞队列        );}

newCacheThreadPool 流程图

public static ExecutorService newCachedThreadPool(){    return new ThreadPoolExecutor(        0,                  // corePoolSoze == 0        Integer.MAX_VALUE,  // maximumPoolSize 非常大        60L,                // 空闲判定是60 秒        TimeUnit.SECONDS,        // 神奇的无存储空间阻塞队列，每个 put 必须要等待一个 take        new SynchronousQueue<Runnable>()      );}

newSingleThreadPool 流程图

public static ExecutorService newSingleThreadExecutor() {        return             new FinalizableDelegatedExecutorService                (                    new ThreadPoolExecutor                        (                            1,                            1,                            0L,                            TimeUnit.MILLISECONDS,                            new LinkedBlockingQueue<Runnable>(),                            threadFactory                        )                );    }