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

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

使用線程池的好處

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

降低資源消耗，通過重復利用已經創建的線程降低線程創建和銷毀造成的消耗。

提高響應速度，當任務到達時，任務可以不需要等到線程創建就能立即執行。

提高線程的可管理性 線程的比較稀缺的資源，如果無限的創建，不僅會消耗系統資源，還會降低系統的穩定性。

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

創建線程池

創建線程池可以使用java中已經內置的一些默認配置的線程池，也可以使用ThreadPoolExecutor來自己配置參數來創建線程池，阿里代碼規約中推薦后者來創建線程池，這樣創建的線程池更加符合業務的實際需求。
下面是我創建線程池的一個例子：

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個參數，我們來解析一下這些參數的意義，這樣下次創建線程池的時候能夠更加靈活的使用。

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

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

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

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

BlockingQueue workQueue (任務隊列)：用于保存等待執行的任務的阻塞隊列。可以選擇的有以下：

ArrayBlockingQueue:基于數組的有界阻塞隊列 FIFO

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

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

PriorityBlockingQueue 具有優先級的無界阻塞隊列

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

AbortPolicy:直接拋出異常

CallerRunsPolicy: 只用調用者所在線程來運行任務

DiscardOldestPolicy :丟棄隊列里最近的一個任務，執行當前任務

DiscardPolicy : 不處理丟棄掉

也可以實現RejectedExecutionHandler接口自定義處理方式。

向線程池提交任務

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

 public static void main(String[] args) {
    //提交沒有返回結果的任務
    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");
        }
    });
    //提交有返回結果的任務，返回一個future的對象，調用get方法獲取返回值，阻塞直到返回
    Future future1 = EXECUTOR_SERVICE.submit(new Callable