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

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

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

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

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

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

ThreadPoolExecutor構(gòu)造方法

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

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

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

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

workQueue設(shè)置不當(dāng)容易導(dǎo)致OOM；

handler設(shè)置不當(dāng)會(huì)導(dǎo)致提交任務(wù)時(shí)拋出異常。

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

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ù)隊(duì)列 -> maximumPoolSize -> 拒絕策略

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

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

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

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

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

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

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

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

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

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

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

ExecutorService executorService = Executors.newFixedThreadPool(4);
Future