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

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

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

先舉個(gè)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("耗時(shí)："+(System.currentTimeMillis()-s1));
            System.out.println("AtomicLong="+al.get());

結(jié)果：

耗時(shí)：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("耗時(shí)："+(System.currentTimeMillis()-s1));
                    System.out.println("AtomicLong="+al.get());
                    break;
                }
                Thread.sleep(1);
            }

結(jié)果：

耗時(shí)：2972
AtomicLong=20000

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

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

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

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

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

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

unit：keepAliveTime的單位。

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

threadFactory：生成新線程的工廠。

handler：當(dāng)線程數(shù)超過workQueue的上限時(shí)，新線程會(huì)被拒絕，這個(gè)參數(shù)就是新線程被拒絕的方式。

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

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

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

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

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

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

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

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

把corePoolSize設(shè)為1，而workQueue大小設(shè)為無限大，因此永遠(yuǎn)只有一個(gè)線程在執(zhí)行任務(wù)，新任務(wù)都在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所有新任務(wù)都會(huì)被立即執(zhí)行，corePoolSize 設(shè)置為0，maximumPoolSize設(shè)置為整數(shù)最大值，所有線程超過60秒未被使用，就會(huì)被銷毀。

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

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

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

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

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

1、AbortPolicy

直接拋出一個(gè)RejectedExecutionException，這也是JDK默認(rèn)的拒絕策略

2、CallerRunsPolicy

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

3、DiscardOldestPolicy

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

4、DiscardPolicy

悄悄地拒絕任務(wù)