摘要：中的線程池運用場景非常廣泛，幾乎所有的一步或者并發(fā)執(zhí)行程序都可以使用。代碼中如果執(zhí)行了方法，線程池會提前創(chuàng)建并啟動所有核心線程。線程池最大數(shù)量線程池允許創(chuàng)建的線程最大數(shù)量。被稱為是可重用固定線程數(shù)的線程池。

Java中的線程池運用場景非常廣泛，幾乎所有的一步或者并發(fā)執(zhí)行程序都可以使用。那么線程池有什么好處呢，以及他的實現(xiàn)原理是怎么樣的呢？

使用線程池的好處

在開發(fā)過程中，合理的使用線程池能夠帶來以下的一些優(yōu)勢，這些優(yōu)勢同時也是一些其他池化的優(yōu)勢，例如數(shù)據(jù)庫連接池，http連接池等。

降低資源消耗，通過重復(fù)利用已經(jīng)創(chuàng)建的線程降低線程創(chuàng)建和銷毀造成的消耗。

提高響應(yīng)速度，當(dāng)任務(wù)到達時，任務(wù)可以不需要等到線程創(chuàng)建就能立即執(zhí)行。

提高線程的可管理性 線程的比較稀缺的資源，如果無限的創(chuàng)建，不僅會消耗系統(tǒng)資源，還會降低系統(tǒng)的穩(wěn)定性。

我們創(chuàng)建線程池完成之后，當(dāng)把一個任務(wù)提交給線程池處理的時候，線程池的處理流程如下：
1）線程池判斷核心線程池的任務(wù)是否都在執(zhí)行任務(wù)，如果不是，則創(chuàng)建一個新的線程來執(zhí)行任務(wù)，如何核心線程池的線程都在執(zhí)行任務(wù)，則進入下一個流程
2）線程池判斷工作隊列是否已滿，如果工作隊列沒有滿，那么新提交的任務(wù)將會存儲在工作隊列中，如果工作隊列滿了，那會進入到下一個流程
3）線程池判斷線程池中的線程是否都處于工作狀態(tài)，如果沒有，則創(chuàng)建一個新的工作線程來執(zhí)行任務(wù)。如果已經(jīng)滿了，那么使用飽和策略來處理這個任務(wù)

創(chuàng)建線程池

創(chuàng)建線程池可以使用java中已經(jīng)內(nèi)置的一些默認(rèn)配置的線程池，也可以使用ThreadPoolExecutor來自己配置參數(shù)來創(chuàng)建線程池，阿里代碼規(guī)約中推薦后者來創(chuàng)建線程池，這樣創(chuàng)建的線程池更加符合業(yè)務(wù)的實際需求。
下面是我創(chuàng)建線程池的一個例子：

ExecutorService executor = new ThreadPoolExecutor(2, 5,  30 , TimeUnit.SECONDS, new ArrayBlockingQueue<>(10), new ThreadPoolExecutor.AbortPolicy());

 public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue workQueue,
                          RejectedExecutionHandler handler) {
    this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
         Executors.defaultThreadFactory(), handler);
}

在上面的這段代碼里new ThreadPoolExecutor中一共有6個參數(shù)，我們來解析一下這些參數(shù)的意義，這樣下次創(chuàng)建線程池的時候能夠更加靈活的使用。

corePoolSize (核心線程的數(shù)量)：任務(wù)提交到線程池時，線程池會創(chuàng)建一個線程來執(zhí)行任務(wù)，即使其他空閑的核心線程能夠執(zhí)行新任務(wù)也會創(chuàng)建線程，等到需要執(zhí)行的任務(wù)數(shù)大于線程池核心數(shù)大小時就不再創(chuàng)建。代碼中如果執(zhí)行了prestartAllCoreThreads()方法，線程池會提前創(chuàng)建并啟動所有核心線程。

maximumPoolSize (線程池最大數(shù)量)：線程池允許創(chuàng)建的線程最大數(shù)量。如果隊列滿了，并且創(chuàng)建的線程數(shù)小于最大線程數(shù)，那么線程池會再創(chuàng)建新的線程執(zhí)行任務(wù)，如果使用無界隊列，那么這個參數(shù)設(shè)置了意義不大。

keepAliveTime (線程保持活動時間)：線程池的工作線程空閑后，保持存活的時間，如果任務(wù)很多，切任務(wù)執(zhí)行時間較長，這個值可以設(shè)置的大一點。

TimeUnit (上面的那個時間的單位)

BlockingQueue workQueue (任務(wù)隊列)：用于保存等待執(zhí)行的任務(wù)的阻塞隊列?？梢赃x擇的有以下：

ArrayBlockingQueue:基于數(shù)組的有界阻塞隊列 FIFO

LinkedBlockingQueue：基于鏈表的有界阻塞隊列 FIFO 吞吐量高于ArrayBlockingQueue， FixedThreadPool基于這個實現(xiàn)

SynchronousQueue: 不存儲元素的阻塞隊列，每個插入操作必須等到另一個線程調(diào)用移除操作，否則插入處于阻塞狀態(tài)，吞吐量高于LinkedBlockingQueue，靜態(tài)方法：Executors.newCachedThreadPool使用了這個隊列

PriorityBlockingQueue 具有優(yōu)先級的無界阻塞隊列

handler (飽和策略)：當(dāng)隊列和線程池都滿了，說明線程池已經(jīng)處于飽和狀態(tài)，那么必須采取一種策略處理新提交的任務(wù)，目前提供四種策略

AbortPolicy:直接拋出異常

CallerRunsPolicy: 只用調(diào)用者所在線程來運行任務(wù)

DiscardOldestPolicy :丟棄隊列里最近的一個任務(wù)，執(zhí)行當(dāng)前任務(wù)

DiscardPolicy : 不處理丟棄掉

也可以實現(xiàn)RejectedExecutionHandler接口自定義處理方式。

向線程池提交任務(wù)

線程池創(chuàng)建完成之后，就可以處理提交的任務(wù)，任務(wù)如何提交到線程池呢，線程池提供了兩個方法：submit()和execute()方法。

 public static void main(String[] args) {
    //提交沒有返回結(jié)果的任務(wù)
    EXECUTOR_SERVICE.execute(new Runnable() {
        @Override
        public void run() {
            System.out.println("hello world");
        }
    });
    Future future = EXECUTOR_SERVICE.submit(new Runnable() {
        @Override
        public void run() {
            System.out.println("hello world1");
        }
    });
    //提交有返回結(jié)果的任務(wù)，返回一個future的對象，調(diào)用get方法獲取返回值，阻塞直到返回
    Future future1 = EXECUTOR_SERVICE.submit(new Callable