通俗易懂，各經常使用線程池執行的-流程圖

時間 2019-11-30

標籤通俗易懂經常使用線程執行流程圖欄目系統架構简体版

原文原文鏈接

做者：林冠宏 / 指尖下的幽靈java

掘金：https://juejin.im/user/587f0dfe128fe100570ce2d8git

博客：http://www.cnblogs.com/linguanh/github

GitHub ： https://github.com/af913337456/併發

有時候花了大把時間去看一些東西卻看不懂，是很「藍瘦」的，花時間也是投資。

本文適合：函數

曾瞭解過線程池卻一直模模糊糊的人
瞭解得差很少卻對某些點依然疑惑的

不適合：spa

徹底沒看過的，建議你先去看看其餘基礎文章
看過，卻忘得差很少了，建議你先去回顧下

本文能給你的閱讀回報

適合的讀者，儘量讓你完全明白經常使用的線程池的知識相關點
不適合的讀者，能有個不錯的概念，神童另談

廢話少說，咱們開始。下圖，皆可自行保存，經常閱之。日久，根深蒂固線程

默認構造函數

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

絕對易懂的構造方法參數講解

參數名	做用
corePoolSize	隊列沒滿時，線程最大併發數
maximumPoolSizes	隊列滿後線程可以達到的最大併發數
keepAliveTime	空閒線程過多久被回收的時間限制
unit	keepAliveTime 的時間單位
workQueue	阻塞的隊列類型
RejectedExecutionHandler	超出 maximumPoolSizes + workQueue 時，任務會交給RejectedExecutionHandler來處理

文字描述

corePoolSize，maximumPoolSize，workQueue之間關係。3d

當線程池中線程數小於corePoolSize時，新提交任務將建立一個新線程執行任務，即便此時線程池中存在空閒線程。代理
當線程池中線程數達到corePoolSize時，新提交任務將被放入workQueue中，等待線程池中任務調度執行。code
當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
                        )
                );
    }
複製代碼