本文總結(jié)一下線程池是怎么回事，分以下幾個部分，對哪個部分感興趣，可以直接跳到對應(yīng)的章節(jié)

　　第一部分：線程池類的結(jié)構(gòu)介紹

　　第二部分：線程池的使用

　　第三部分：線程池的創(chuàng)建流程

　　第四部分：線程池的應(yīng)用場景

　　第五部分：線程池相關(guān)的面試題

第一部分：線程池類的結(jié)構(gòu)

線程池存在于Java的并發(fā)包J.U.C中，線程池可以根據(jù)項目靈活控制并發(fā)的數(shù)目，避免頻繁的創(chuàng)建和銷毀線程，達到線程對象的重用。

下面是線程池的類圖：

1、接口Executor

接口Executor中，只有一個方法，為execute()

2、接口ExecutorService，繼承自Executor

幾個重要的方法：

(1)關(guān)閉線程池的方法，有兩種

一個ExecutorService(J.U.C)可以關(guān)閉，這將導(dǎo)致它拒絕新的任務(wù)。 ExecutorService的兩種關(guān)閉線程池的方式，shutdown和shutdownNow方法：

　　①shutdown()：拒收新的任務(wù)，立馬關(guān)閉正在執(zhí)行的任務(wù)，可能會引起報錯，需要異常捕獲

　?、趕hutdownNow()：拒收新的任務(wù)，等待任務(wù)執(zhí)行完畢，要確保任務(wù)里不會有永久等待阻塞的邏輯，否則會導(dǎo)致線程關(guān)閉不了

　?、鄄皇邱R上關(guān)閉，要想等待線程池關(guān)閉，還需要調(diào)用waitFermination來阻塞等待

　　④還有一些業(yè)務(wù)場景下，需要知道線程池中的任務(wù)是否全部執(zhí)行完成，當我們關(guān)閉線程池之后，可以用isTerminated來判斷所有的線程是否執(zhí)行完成，千萬不要用isShutdown，　　它只是返回你是否調(diào)用過shutdown的結(jié)果

(2)submit()方法

方法submit延伸的方法Executor.execute(Runnable)通過創(chuàng)建并返回一個Future可用于取消執(zhí)行和/或等待完成。submit()與execute()的一個區(qū)別是submit()有返回值，并且能夠處理　　異常

3、Executors(J.U.C)，提供了6個靜態(tài)方法，分別創(chuàng)建6種不同的線程池，六大靜態(tài)方法 內(nèi)部都是直接或間接調(diào)用ThreadPoolExecutor類的構(gòu)造方法創(chuàng)建線程池對象，這六個靜態(tài)方法　　本身是沒有技術(shù)含量的。

　　

Executors(類)	Executors靜態(tài)方法	實現(xiàn)類
	newCachedThreadPool	ThreadPoolExecutor
	newFixedThreadPool	ThreadPoolExecutor
	newSingleThreadExecutor	ThreadPoolExecutor
	newScheduledThreadPool	ScheduledThreadPoolExecutor
	newSingleThreadScheduledExecutor	ScheduledThreadPoolExecutor
	newWorkStealingPool	ForkJoinPool
Executor(接口)：只有一個方法execute()

下面介紹常用的四種：

(1)FixedThreadPool

FixedThreadPool的特點：固定池子中線程的個數(shù)。使用靜態(tài)方法newFixedThreadPool()創(chuàng)建線程池的時候指定線程池個數(shù)。

(2)CachedThreadPool（彈性緩存線程池）

CachedThreadPool的特點：用newCachedThreadPool()方法創(chuàng)建該線程池對象，創(chuàng)建之初里面一個線程都沒有，當execute方法或submit方法向線程池提交任務(wù)時，會自動新建線程；如果線程池中有空余線程，則不會新建；這種線程池一般最多情況可以容納幾萬個線程，里面的線程空余60s會被回收。

(3)SingleThreadPool（單線程線程池）

SingleThreadPool的特點：池中只有一個線程，如果扔5個任務(wù)進來，那么有4個任務(wù)將排隊；作用是保證任務(wù)的順序執(zhí)行。

(4)ScheduledThreadpool（定時器線程池）

　　注意：要用ScheduledExecutorService去創(chuàng)建ScheduledThreadpool，如果用Executor去引用，就只能調(diào)用Executor接口中定義的方法；如果用ExecutorService接口去引用，就只能調(diào)用ExecutorService接口中定義的方法，無法使用ScheduledExecutorService接口中新增的方法，那么也就失去了這種線程池的意義

第二部分：線程池的使用

第一種方式，構(gòu)建一個線程池

ExecutorService threadPool = Executors.newFixedThreadPool(10);

第二種方式，使用ThreadPoolExecutor構(gòu)建一個線程池

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class test {
    public static void main(String args[]) {
        ExecutorService executorService = new ThreadPoolExecutor(5,10,
                10,TimeUnit.SECONDS,new ArrayBlockingQueue<Runnable>(5));
        executorService.execute(new Runnable() {
            @Override
            public void run() {
                System.out.println("開始執(zhí)行線程池中的任務(wù)");
            }
        });
    }
}

如果只是簡單的想要改變線程名稱的前綴的話可以自定義ThreadFactory來實現(xiàn)，在Executors.new…中有一個ThreadFactory的參數(shù)，如果沒有指定則用的是DefaultThreadFactory。

第三種方式，使用工具來創(chuàng)建線程池，Apache的guava中ThreadFactoryBuilder()來創(chuàng)建線程池，不僅可以避免OOM問題，還可以自定義線程名稱，方便出錯時溯源

第三部分：線程池的流程梳理

1、線程池的參數(shù)

　　(1) corePoolSize：核心線程數(shù)的大小

　　(2) maximumPoolSize：最大線程數(shù)的大小

　　(3) keepAliveTime：線程的空閑時間

　　(4) TimeUnit：空閑時間的單位

　　(5) workQueue：阻塞隊列

　　(6) threadFactory：線程工廠

　　(7) Handler：拒絕策略

參數(shù)的詳細說明：

　　(1) corePoolSize：池子里的線程數(shù)的大小，設(shè)置allowCoreThreadTimeOut(true)使核心線程數(shù)內(nèi)的線程也可以被回收

　　(2) maximumPoolSize：當池子里的線程數(shù)達到核心線程數(shù)的大小，隊列也滿了，可以繼續(xù)創(chuàng)建的線程，直到線程數(shù)達到maximumPoolSize

　　(3) keepAliveTime：線程的空閑時間，是跟核心線程數(shù)和最大線程數(shù)之間的線程相關(guān)，這部分線程，當?shù)竭_規(guī)定的空閑時間還沒有獲取到任務(wù)，則會被回收

　　(4) TimeUnit：空閑時間的單位

　　(5) workQueue：默認支持4種阻塞隊列

　　　?、貯rrayBlockingQueue，基于數(shù)組的有界阻塞隊列，按FIFO排序。新任務(wù)進來后，會放到該隊列的隊尾，有界的數(shù)組可以防止資源耗盡問題。

　　　　②LinkedBlockingQuene，基于鏈表的無界阻塞隊列（其實最大容量為Interger.MAX），按照FIFO排序。由于該隊列的近似無界性，當線程池中線程數(shù)量達到corePoolSize　　　　　　后，再有新任務(wù)進來，會一直存入該隊列，而不會去創(chuàng)建新線程直到maxPoolSize，因此使用該工作隊列時，參數(shù)maxPoolSize其實是不起作用的。

　　　?、跾ynchronousQuene，一個不緩存任務(wù)的阻塞隊列，生產(chǎn)者放入一個任務(wù)必須等到消費者取出這個任務(wù)。也就是說新任務(wù)進來時，不會緩存，而是直接被調(diào)度執(zhí)行該任務(wù)，　　　　　如果沒有可用線程，則創(chuàng)建新線程，如果線程數(shù)量達到maxPoolSize，則執(zhí)行拒絕策略。

　　　?、躊riorityBlockingQueue，具有優(yōu)先級的無界阻塞隊列，優(yōu)先級通過參數(shù)Comparator實現(xiàn)。

　　(6) threadFactory：線程工廠，用來創(chuàng)建一個新線程時使用的工廠，可以用來設(shè)定線程名，是否為daemon線程等

　　(7) Handler：拒絕策略

　　　　①CallerRunsPolicy(直接拒絕任務(wù))，該策略下，在調(diào)用者線程中直接執(zhí)行被拒絕任務(wù)的run方法，除非線程池已經(jīng)shutdown，則直接拋棄任務(wù)。

　　　?、贏bortPolicy(直接丟棄任務(wù)，并拋異常)，該策略下，直接丟棄任務(wù)，并拋出RejectedExecutionException異常。

　　　　③DiscardPolicy(直接丟棄任務(wù)，什么都不做)，該策略下，直接丟棄任務(wù)，什么都不做。

　　　?、蹹iscardOldestPolicy(嘗試添加新任務(wù))，該策略下，拋棄進入隊列最早的那個任務(wù)，然后嘗試把這次拒絕的任務(wù)放入隊列

2、線程池的運行過程

　　(1)剛開始運行時，線程池是空的

　　(2)一個任務(wù)進來，檢查池中的線程數(shù)量，是否達到corePoolSize，如果沒有達到，則創(chuàng)建線程，執(zhí)行任務(wù)

　　(3)任務(wù)執(zhí)行完成之后，線程不會銷毀，而是阻塞的等待下一個任務(wù)

　　(4) 又進來一個任務(wù)，不是直接使用阻塞的線程，而是檢查線程池中的線程數(shù)大小，是否達到corePoolSize，如果沒有達到，則繼續(xù)創(chuàng)建新的線程，來執(zhí)行新的任務(wù)，如此往復(fù)，　　直到線程池中的線程數(shù)達到corePoolSize，此時停止創(chuàng)建新的線程

　　(5)此時，又來新的任務(wù)，會選擇線程池中阻塞等待的線程來執(zhí)行任務(wù)，有一個任務(wù)進來，喚醒一個線程來執(zhí)行這個任務(wù)，處理完之后，再次阻塞，嘗試在workQueue上獲取下一　　個任務(wù)，如果線程池中沒有可喚醒的線程，則任務(wù)進入workQueue，排隊等待

　　(6)如果隊列是無界隊列，比如LinkedBlockingQueue，默認最大容量為Integer.MAX，接近于無界，可用無限制的接收任務(wù)，如果隊列是有界隊列，比如ArrayBlockingQueue，可限定隊列大小，當線程池中的線程來不及處理，然后，所有的任務(wù)都進入隊列，隊列的任務(wù)數(shù)也達到限定大小，此時，再來新的任務(wù)，就會入隊失敗，然后，就會再次嘗試在線程池里創(chuàng)建線程，直到線程數(shù)達到maximumPoolSize，停止創(chuàng)建線程

　　(7)此時，隊列滿了，新的任務(wù)無法入隊，創(chuàng)建的線程數(shù)也達到了maximumPoolSize，無法再創(chuàng)建新的線程，此時，就會reject掉，使用拒絕策略RejectedExecutionHandler，不讓繼續(xù)提交任務(wù)，默認的是AbortPolicy策略，拒絕，并拋出異常

　　(8)超出corePoolSize數(shù)創(chuàng)建的那部分線程，是跟空閑時間keepAliveTime相關(guān)的，如果超過keepAliveTime時間還獲取不到任務(wù)，線程會被銷毀，自動釋放掉

第四部分：線程池的應(yīng)用場景

1、newSingleThreadExecutor：一個單線程的線程池，可以用于需要保證順序執(zhí)行的場景，并且只有一個線程在執(zhí)行。

2、newFixedThreadPool：一個固定大小的線程池，可以用于已知并發(fā)壓力的情況下，對線程數(shù)做限制。

3、newCachedThreadPool：一個可以無限擴大的線程池，比較適合處理執(zhí)行時間比較小的任務(wù)。

4、newScheduledThreadPool：可以延時啟動，定時啟動的線程池，適用于需要多個后臺線程執(zhí)行周期任務(wù)的場景。

5、newWorkStealingPool：一個擁有多個任務(wù)隊列的線程池，可以減少連接數(shù)，創(chuàng)建當前可用cpu數(shù)量的線程來并行執(zhí)行。

線程池的實際業(yè)務(wù)場景：線程池適合單系統(tǒng)的大量的異步任務(wù)處理，比如發(fā)送短信、保存日志。

第五部分：線程池相關(guān)的面試題

1、為什么使用線程池，線程池有什么作用？

　　線程池，就是一個池子，存放指定數(shù)量的線程來執(zhí)行任務(wù)，處理完任務(wù)的線程不進行回收，而是阻塞等待下一個任務(wù)，避免了頻繁的創(chuàng)建和銷毀線程，達到了線程的重用。

2、如何創(chuàng)建一個線程池？

　　最常用的，使用ThreadPoolExecutor實現(xiàn)類來創(chuàng)建線程池

3、如何關(guān)閉一個線程池？

　　ExecutorService提供了兩種方法來關(guān)閉線程池，shutdown()和shutdownNow()

　　(1) shutdown：拒收新的任務(wù)，立馬關(guān)閉正在執(zhí)行的任務(wù)，可能會引起報錯，需要異常捕獲

　　(2) shutdownNow：拒收新的任務(wù)，等待任務(wù)執(zhí)行完畢，要確保任務(wù)里不會有永久等待阻塞的邏輯，否則會導(dǎo)致線程關(guān)閉不了

　　不是馬上關(guān)閉，要想等待線程池關(guān)閉，還需要調(diào)用waitFermination來阻塞等待

　 還有一些業(yè)務(wù)場景下，需要知道線程池中的任務(wù)是否全部執(zhí)行完成，當我們關(guān)閉線程池之后，可以用isTerminated來判斷所有的線程是否執(zhí)行完成，千萬不要用isShutdown，它只　　是返回你是否調(diào)用過shutdown的結(jié)果

4、submit()和execute()方法的區(qū)別？

　　execute()方法在Executor()接口中，且是接口中唯一的方法

　　submit()方法在ExecutorService中，ExecutorService接口繼承Executor 接口

　　execute()方法，開啟線程執(zhí)行池中的任務(wù)

　　submit()方法，也可以做到execute()的作用，它還可以返回執(zhí)行結(jié)果，它的 功能是提交指定的任務(wù)去執(zhí)行并且返回Future對象(即執(zhí)行的結(jié)果)

　　submit()和execute()的區(qū)別：

　　1)接收的參數(shù)不一樣

　　2)submit()方法有返回值Future，而execute()方法沒有返回值

　　3)submit()方法方便處理Exception異常，意思就是，你在task里會拋出checked或者unchecked exception， 而又希望外面的調(diào)用者能夠感知這些exception并作出及時的處理，用 submit，通過捕獲Future.get拋出的異常

5、為什么不建議使用Executors創(chuàng)建線程，而使用ThreadPoolExecutor實現(xiàn)類來創(chuàng)建線程？

　　Executors中FixedThreadPool使用的是LinkedBlockingQueue隊列，近乎于無界，隊列大小默認為Integer.MAX_VALUE，幾乎可以無限制的放任務(wù)到隊列中，線程池中數(shù)量是固定的，當線程池中線程數(shù)量達到corePoolSize，不會再創(chuàng)建新的線程，所有任務(wù)都會入隊到workQueue中，線程從workQueue中獲取任務(wù)，但這個隊列幾乎永遠不會滿，只要隊列不滿，就不會再去創(chuàng)建新的線程，就跟maximumPoolSize和keepAliveTime沒有關(guān)系，此時，如果線程池中的線程處理任務(wù)的時間特別長，導(dǎo)致無法處理新的任務(wù)，隊列中的任務(wù)就會不斷的積壓，這個過程，會導(dǎo)致機器的內(nèi)存使用不停的飆升，極端情況下會導(dǎo)致JVM OOM，系統(tǒng)就掛了。

　　總結(jié)：Executors中FixedThreadPool指定使用無界隊列LinkedBlockingQueue會導(dǎo)致內(nèi)存溢出，所以，最好使用ThreadPoolExecutor自定義線程池

　　換一種問法：線程池中，無界隊列導(dǎo)致的內(nèi)存飆升問題，同上

6、線程池如何調(diào)優(yōu)

　　(1)首先，根據(jù)不同的需求選擇線程池，如果需要單線程順序執(zhí)行，使用SingleThreadExecutor，如果已知并發(fā)壓力，使用FixedThreadPool，固定線程數(shù)的大小，執(zhí)行時間小的任務(wù)，可以使用CachedThreadPool，創(chuàng)建可緩存的線程池，可以無限擴大線程池，可以靈活回收空閑線程，最多可容納幾萬個線程，線程空余60s會被回收，需要后臺執(zhí)行周期任務(wù)的，可以使用ScheduledThreadPool，可以延時啟動和定時啟動線程池，

　　(2)如何確認線程池的最大線程數(shù)目，分CPU密集型和IO密集型，如果是CPU密集型或計算密集型，因為CPU的利用率高，核心線程數(shù)可設(shè)置為n(核數(shù))+1，如果是IO密集型，CPU利用率不高，可多給幾個線程數(shù)，來進行工作，核心線程數(shù)可設(shè)置為2n(核數(shù))

總結(jié)

以上是生活随笔為你收集整理的python | 线程池面试题的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。