摘要：雖然使用很方便，但是建議大家使用已經(jīng)設定的幾種線程池無界線程池，可以進行線程自動回收固定大小線程池和單個后線程，它們滿足大部分的場景需求。固定大小線程池和有些類似，只不過從單線程變成可以指定線程數(shù)量，依舊為無限。

池的概念在java中也是常見，還有連接池、常量池等，池的作用也是類似的，對于對象、資源的重復利用，減小系統(tǒng)開銷，提升運行效率。

線程池的主要功能：
1.減少創(chuàng)建和銷毀線程的次數(shù)，提升運行性能，尤其是在大量異步任務時
2.可以更合理地管理線程，如：線程的運行數(shù)量，防止同一時間大量任務運行，導致系統(tǒng)崩潰

先舉個demo，看看使用線程池的區(qū)別，線程池：

AtomicLong al = new AtomicLong(0l);
            Long s1 = System.currentTimeMillis();
            ThreadPoolExecutor pool = new ThreadPoolExecutor(5, 100000, 100, TimeUnit.SECONDS, new LinkedBlockingDeque(20000));
            for(int i=0;i<20000;i++){
                pool.execute(new Runnable() {
                    
                    @Override
                    public void run() {
                        try {
                            al.incrementAndGet();
                        } catch (Exception e) {
                            e.printStackTrace();
                        }
                    }
                });
            }
            pool.shutdown();
            pool.awaitTermination(1, TimeUnit.HOURS);
            System.out.println("耗時："+(System.currentTimeMillis()-s1));
            System.out.println("AtomicLong="+al.get());

結果：

耗時：224
AtomicLong=20000

非線程池：

AtomicLong al = new AtomicLong(0l);            
            Long s1 = System.currentTimeMillis();
            for(int i=0;i<20000;i++){
                Thread t = new Thread(new Runnable() {
                    
                    @Override
                    public void run() {
                        try {
                            al.incrementAndGet();
                        } catch (Exception e) {
                            e.printStackTrace();
                        }
                    }
                });
                t.start();
            }
            while(true){
                if(al.get()==20000){
                    System.out.println("耗時："+(System.currentTimeMillis()-s1));
                    System.out.println("AtomicLong="+al.get());
                    break;
                }
                Thread.sleep(1);
            }

結果：

耗時：2972
AtomicLong=20000

從耗時看2者相差了13倍，差距還是挺大的，可見有大量異步任務時使用線程池能夠提升性能。

    public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue workQueue,
                              ThreadFactory threadFactory,
                              RejectedExecutionHandler handler) {

線程池的主要參數(shù)有這6個：

corePoolSize：核心池的大小，核心池的線程不會被回收，沒有任務就處于空閑狀態(tài)。

maximumPoolSize：線程池最大允許的線程數(shù)，

keepAliveTime：當線程數(shù)超過corePoolSize時，但小于等于maximumPoolSize，會生成‘臨時’線程，‘臨時’線程執(zhí)行完任務不會馬上被回收，如果在keepAliveTime時間內，還沒有新任務的話，才會被回收。

unit：keepAliveTime的單位。

workQueue：當前線程數(shù)超過corePoolSize大小時，新任務會處在等待狀態(tài)，存在workQueue中。

threadFactory：生成新線程的工廠。

handler：當線程數(shù)超過workQueue的上限時，新線程會被拒絕，這個參數(shù)就是新線程被拒絕的方式。

其中corePoolSize和maximumPoolSize相對難理解，再詳細說明：
1、池中線程數(shù)小于corePoolSize，新任務都不排隊而是直接添加新線程

2、池中線程數(shù)大于等于corePoolSize，workQueue未滿，首選將新任務加入workQueue而不是添加新線程

3、池中線程數(shù)大于等于corePoolSize，workQueue已滿，但是線程數(shù)小于maximumPoolSize，添加新的線程來處理被添加的任務

4、池中線程數(shù)大于大于corePoolSize，workQueue已滿，并且線程數(shù)大于等于maximumPoolSize，新任務被拒絕，使用handler處理被拒絕的任務

因此maximumPoolSize、corePoolSize不宜設置過大，否則會造成內存、cpu過載的問題，workQueue而盡量可以大一些。

雖然ThreadPoolExecutor使用很方便，但是建議大家使用jdk已經(jīng)設定的幾種線程池：
Executors.newCachedThreadPool()（無界線程池，可以進行線程自動回收）、Executors.newFixedThreadPool(int)（固定大小線程池）和Executors.newSingleThreadExecutor()（單個后線程），它們滿足大部分的場景需求。

1.newSingleThreadExecutor 單線程線程池
看下它的實現(xiàn)方式：

    public static ExecutorService newSingleThreadExecutor() {
        return new FinalizableDelegatedExecutorService
            (new ThreadPoolExecutor(1, 1,
                                    0L, TimeUnit.MILLISECONDS,
                                    new LinkedBlockingQueue()));
    }

把corePoolSize設為1，而workQueue大小設為無限大，因此永遠只有一個線程在執(zhí)行任務，新任務都在workQueue中等待。

2.newFixedThreadPool 固定大小線程池

    public static ExecutorService newFixedThreadPool(int nThreads) {
        return new ThreadPoolExecutor(nThreads, nThreads,
                                      0L, TimeUnit.MILLISECONDS,
                                      new LinkedBlockingQueue());
    }

和newSingleThreadExecutor 有些類似，只不過從單線程變成可以指定線程數(shù)量，workQueue依舊為無限。
3.newCachedThreadPool

    public static ExecutorService newCachedThreadPool() {
        return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                      60L, TimeUnit.SECONDS,
                                      new SynchronousQueue());
    }

newCachedThreadPool所有新任務都會被立即執(zhí)行，corePoolSize 設置為0，maximumPoolSize設置為整數(shù)最大值，所有線程超過60秒未被使用，就會被銷毀。

當前線程數(shù)超過corePoolSize大小時，新任務會處在等待狀態(tài)，存在workQueue中。workQueue的實現(xiàn)方式也就是任務的等待策略，分為3種：有限隊列、無限隊列、直接提交。

談談前2種，jdk使用了LinkedBlockingQueue而非ArrayBlockingQueue，有限隊列的優(yōu)勢在于對資源和效率更定制化的配置，但是對比無限隊列缺點也很明顯：

1).增加開發(fā)難度。需要考慮到corePoolSize ，maximumPoolSize，workQueue，3個參數(shù)大小，既要使任務高效地執(zhí)行，又要避免任務超量的問題，對于開發(fā)和測試的復雜度提高很多。
2).防止業(yè)務突刺。在互聯(lián)網(wǎng)應用業(yè)務量暴增也是必須考慮的問題，在使用無限隊列時，雖然執(zhí)行可能慢一點，但是能保證執(zhí)行到。使用有限隊列，會出現(xiàn)任務拒絕的問題。
綜上考慮，更建議使用無限隊列，尤其是對于多線程不是很熟悉的朋友們。

所謂拒絕策略之前也提到過了，任務太多，超過maximumPoolSize了怎么辦？當然是接不下了，接不下那只有拒絕了。拒絕的時候可以指定拒絕策略，也就是一段處理程序。

決絕策略的父接口是RejectedExecutionHandler，JDK本身在ThreadPoolExecutor里給用戶提供了四種拒絕策略，看一下：

1、AbortPolicy

直接拋出一個RejectedExecutionException，這也是JDK默認的拒絕策略

2、CallerRunsPolicy

嘗試直接運行被拒絕的任務，如果線程池已經(jīng)被關閉了，任務就被丟棄。

3、DiscardOldestPolicy

移除最晚的那個沒有被處理的任務，然后執(zhí)行被拒絕的任務。同樣，如果線程池已經(jīng)被關閉了，任務就被丟棄了

4、DiscardPolicy

悄悄地拒絕任務