Java线程池执行流程图，简单易懂-CSDN博客

点击关注公众号，利用碎片时间学习

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

本文适合：

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

不适合：

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

本文能给你的阅读回报

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

废话少说，我们开始。下图，皆可自行保存，常常阅之。日久，根深蒂固

默认构造函数

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

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

图片

文字描述

corePoolSize，maximumPoolSize，workQueue之间关系。

当线程池中线程数小于corePoolSize时，新提交任务将创建一个新线程执行任务，即使此时线程池中存在空闲线程。
当线程池中线程数达到corePoolSize时，新提交任务将被放入workQueue中，等待线程池中任务调度执行。
当workQueue已满，且maximumPoolSize > corePoolSize时，新提交任务会创建新线程执行任务。
当workQueue已满，且提交任务数超过maximumPoolSize，任务由RejectedExecutionHandler处理。
当线程池中线程数超过corePoolSize，且超过这部分的空闲时间达到keepAliveTime时，回收这些线程。
当设置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  
                        )  
                );  
    }

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

区别就在于：