摘要：最近項目中越來越多需要異步調(diào)用的地方，系統(tǒng)中雖有線程池管理，但還有可優(yōu)化的空間，通過分享該文章，幫助大家了解線程池，同時學習使用線程池開啟線程需要注意的地方。沒錯，上述方法創(chuàng)建的線程池就是。線程池就是程序中的裝修公司，代勞各種臟活累活。

最近項目中越來越多需要異步調(diào)用的地方，系統(tǒng)中雖有線程池管理，但還有可優(yōu)化的空間，通過分享該文章，幫助大家了解線程池，同時學習使用線程池開啟線程需要注意的地方。

構(gòu)造一個線程池為什么需要幾個參數(shù)？如果避免線程池出現(xiàn)OOM？Runnable和Callable的區(qū)別是什么？本文將對這些問題一一解答，同時還將給出使用線程池的常見場景和代碼片段。

Java中創(chuàng)建線程池很簡單，只需要調(diào)用Executors中相應(yīng)的便捷方法即可，比如Executors.newFixedThreadPool(int nThreads)，但是便捷不僅隱藏了復(fù)雜性，也為我們埋下了潛在的隱患（OOM，線程耗盡）。

Executors創(chuàng)建線程池便捷方法列表：

小程序使用這些快捷方法沒什么問題，對于服務(wù)端需要長期運行的程序，創(chuàng)建線程池應(yīng)該直接使用ThreadPoolExecutor的構(gòu)造方法。沒錯，上述Executors方法創(chuàng)建的線程池就是ThreadPoolExecutor。

ThreadPoolExecutor構(gòu)造方法

Executors中創(chuàng)建線程池的快捷方法，實際上是調(diào)用了ThreadPoolExecutor的構(gòu)造方法（定時任務(wù)使用的是ScheduledThreadPoolExecutor），該類構(gòu)造方法參數(shù)列表如下：

// Java線程池的完整構(gòu)造函數(shù)
public ThreadPoolExecutor(
  int corePoolSize, // 線程池長期維持的線程數(shù)，即使線程處于Idle狀態(tài)，也不會回收。
  int maximumPoolSize, // 線程數(shù)的上限
  long keepAliveTime, TimeUnit unit, // 超過corePoolSize的線程的idle時長，
                                     // 超過這個時間，多余的線程會被回收。
  BlockingQueue workQueue, // 任務(wù)的排隊隊列
  ThreadFactory threadFactory, // 新線程的產(chǎn)生方式
  RejectedExecutionHandler handler) // 拒絕策略

竟然有7個參數(shù)，很無奈，構(gòu)造一個線程池確實需要這么多參數(shù)。這些參數(shù)中，比較容易引起問題的有corePoolSize, maximumPoolSize, workQueue以及handler：

corePoolSize和maximumPoolSize設(shè)置不當會影響效率，甚至耗盡線程；

workQueue設(shè)置不當容易導致OOM；

handler設(shè)置不當會導致提交任務(wù)時拋出異常。

正確的參數(shù)設(shè)置方式會在下文給出。

If fewer than corePoolSize threads are running, the Executor always prefers adding a new thread rather than queuing.
If corePoolSize or more threads are running, the Executor always prefers queuing a request rather than adding a new thread.
If a request cannot be queued, a new thread is created unless this would exceed maximumPoolSize, in which case, the task will be rejected.

corePoolSize -> 任務(wù)隊列 -> maximumPoolSize -> 拒絕策略

可以向線程池提交的任務(wù)有兩種：Runnable和Callable，二者的區(qū)別如下：

方法簽名不同，void Runnable.run(), V Callable.call() throws Exception
是否允許有返回值，Callable允許有返回值
是否允許拋出異常，Callable允許拋出異常。

Callable是JDK1.5時加入的接口，作為Runnable的一種補充，允許有返回值，允許拋出異常。

不要使用Executors.newXXXThreadPool()快捷方法創(chuàng)建線程池，因為這種方式會使用無界的任務(wù)隊列，為避免OOM，我們應(yīng)該使用ThreadPoolExecutor的構(gòu)造方法手動指定隊列的最大長度：

ExecutorService executorService = new ThreadPoolExecutor(2, 2, 
                0, TimeUnit.SECONDS, 
                new ArrayBlockingQueue<>(512), // 使用有界隊列，避免OOM
                new ThreadPoolExecutor.DiscardPolicy());

任務(wù)隊列總有占滿的時候，這是再submit()提交新的任務(wù)會怎么樣呢？RejectedExecutionHandler接口為我們提供了控制方式，接口定義如下：

public interface RejectedExecutionHandler {
    void rejectedExecution(Runnable r, ThreadPoolExecutor executor);
}

線程池給我們提供了幾種常見的拒絕策略：

線程池默認的拒絕行為是AbortPolicy，也就是拋出RejectedExecutionHandler異常，該異常是非受檢異常，很容易忘記捕獲。如果不關(guān)心任務(wù)被拒絕的事件，可以將拒絕策略設(shè)置成DiscardPolicy，這樣多余的任務(wù)會悄悄的被忽略。

ExecutorService executorService = new ThreadPoolExecutor(2, 2, 
                0, TimeUnit.SECONDS, 
                new ArrayBlockingQueue<>(512), 
                new ThreadPoolExecutor.DiscardPolicy());// 指定拒絕策略

線程池的處理結(jié)果、以及處理過程中的異常都被包裝到Future中，并在調(diào)用Future.get()方法時獲取，執(zhí)行過程中的異常會被包裝成ExecutionException，submit()方法本身不會傳遞結(jié)果和任務(wù)執(zhí)行過程中的異常。獲取執(zhí)行結(jié)果的代碼可以這樣寫：

ExecutorService executorService = Executors.newFixedThreadPool(4);
Future