為什么80%的碼農(nóng)都做不了架構(gòu)師？>>> ??

相信大多數(shù)接觸過多線程的朋友都會有這樣的困惑，明明使用了多線程，為何還是一團糟？用下面兩幅圖再合適不過了： 理想情況下的多線程VS 現(xiàn)實中：

或者像這樣：

像這樣：

太糟心了實在是，是時候?qū)Χ嗑€程了解的更透徹一點了。我們從線程說起，

| 什么是線程

線程是比進程更小的運行單位，一個進程只少有一個(主線程)或多個線程，每個線程完成不同的任務(wù)；而每個進程都需要操作系統(tǒng)為其分配獨立的內(nèi)存地址空間，而同一進程中的所有線程在同一內(nèi)存地址空間，它們共享同一塊內(nèi)存空間中的資源。 因此，相較進程，線程間 1.可共享數(shù)據(jù)；2.不必重新為線程分配系統(tǒng)資源，代價小； java中內(nèi)置了多線程功能的支持，也為我們使用多線程提供了方便；

附上線程使用的方法： 1、繼承Thread類 2、實現(xiàn)Runnable接口 3、通過Callable和Future創(chuàng)建線程

線程生命周期快速預覽：

新建狀態(tài)-》就緒-》運行-》阻塞-》死亡；

線程管理快速預覽：

1.睡眠sleep；2.讓步y(tǒng)ield；3.合并join；4.設(shè)置優(yōu)先級Priority；5.設(shè)置守護線程Deamon；6.正確結(jié)束線程；

線程同步快速預覽： 1.使用同步方法，synchronized關(guān)鍵字修飾的方法； 2.使用同步代碼塊，synchronized關(guān)鍵字修飾的代碼塊； 3.使用volatile； 4.使用重入鎖，Lock

線程通信快速預覽： 1.wait()、notify()和notifyAll()方法； 2.使用Condition； 3.使用阻塞隊列，BlockingQueue；

| 什么是多線程

多個線程并發(fā)執(zhí)行； 字面上理解很簡單，但真正做到多個線程并發(fā)執(zhí)行，還是需要下功夫的，需要掌握線程的生命周期，處理好線程的同步問題，線程之間的通信，以及最最不愿看到的線程的死鎖的處理。

| 為什么要用線程池:

在java中，如果每個請求到達就創(chuàng)建一個新線程，開銷是相當大的。在實際使用中，服務(wù)器在創(chuàng)建和銷毀線程上花費的時間和消耗的系統(tǒng)資源都相當大，甚至可能要比在處理實際的用戶請求的時間和資源要多的多。除了創(chuàng)建和銷毀線程的開銷之外，活動的線程也需要消耗系統(tǒng)資源。

1.減少創(chuàng)建和銷毀線程的次數(shù)，每個工作線程都可以被重復利用，可執(zhí)行多個任務(wù)。 2.可以根據(jù)系統(tǒng)的承受能力，調(diào)整線程池中工作線線程的數(shù)目，防止因為消耗過多的內(nèi)存，而把服務(wù)器累趴下(每個線程需要大約1MB內(nèi)存，線程開的越多，消耗的內(nèi)存也就越大，最后死機)。

| 線程池的組成：

線程池管理器、工作線程、任務(wù)列隊、任務(wù)接口等部分

線程池管理器至少有下列功能：創(chuàng)建線程池，銷毀線程池，添加新任務(wù)。 工作線程是一個可以循環(huán)執(zhí)行任務(wù)的線程，在沒有任務(wù)時將等待。 任務(wù)接口是為所有任務(wù)提供統(tǒng)一的接口，以便工作線程處理。任務(wù)接口主要規(guī)定了任務(wù)的入口，任務(wù)執(zhí)行完后的收尾工作，任務(wù)的執(zhí)行狀態(tài)等。

| 相關(guān)API

Java里面線程池的頂級接口是Executor，但是嚴格意義上講Executor并不是一個線程池，而只是一個執(zhí)行線程的工具。真正的線程池接口是ExecutorService。

ThreadPoolExecutor的完整構(gòu)造方法的簽名是：

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) .

各個參數(shù)說明： corePoolSize - 池中所保存的線程數(shù)，包括空閑線程。 maximumPoolSize - 池中允許的最大線程數(shù)。 keepAliveTime - 當線程數(shù)大于核心時，此為終止前多余的空閑線程等待新任務(wù)的最長時間。 unit - keepAliveTime 參數(shù)的時間單位。 workQueue - 執(zhí)行前用于保持任務(wù)的隊列。此隊列僅保持由 execute 方法提交的 Runnable 任務(wù)。 threadFactory - 執(zhí)行程序創(chuàng)建新線程時使用的工廠。 handler - 由于超出線程范圍和隊列容量而使執(zhí)行被阻塞時所使用的處理程序。 ThreadPoolExecutor是Executors類的底層實現(xiàn)。

在JDK幫助文檔中，有如此一段話：

“強烈建議程序員使用較為方便的 Executors 工廠方法 Executors.newCachedThreadPool()（無界線程池，可以進行自動線程回收）、Executors.newFixedThreadPool(int)（固定大小線程池） Executors.newSingleThreadExecutor()（單個后臺線程），它們均為大多數(shù)使用場景預定義了設(shè)置。”

比較重要的幾個類：

ExecutorService 真正的線程池接口。 ScheduledExecutorService 能和Timer/TimerTask類似，解決那些需要任務(wù)重復執(zhí)行的問題。 ThreadPoolExecutor ExecutorService的默認實現(xiàn)。 ScheduledThreadPoolExecutor 繼承ThreadPoolExecutor的ScheduledExecutorService接口實現(xiàn)，周期性任務(wù)調(diào)度的類實現(xiàn)。

要配置一個線程池是比較復雜的，尤其是對于線程池的原理不是很清楚的情況下，很有可能配置的線程池不是較優(yōu)的，因此在Executors類里面提供了一些靜態(tài)工廠，生成一些常用的線程池。

newSingleThreadExecutor

創(chuàng)建一個單線程的線程池。這個線程池只有一個線程在工作，也就是相當于單線程串行執(zhí)行所有任務(wù)。如果這個唯一的線程因為異常結(jié)束，那么會有一個新的線程來替代它。此線程池保證所有任務(wù)的執(zhí)行順序按照任務(wù)的提交順序執(zhí)行。

newFixedThreadPool

創(chuàng)建固定大小的線程池。每次提交一個任務(wù)就創(chuàng)建一個線程，直到線程達到線程池的最大大小。線程池的大小一旦達到最大值就會保持不變，如果某個線程因為執(zhí)行異常而結(jié)束，那么線程池會補充一個新線程。

newCachedThreadPool

創(chuàng)建一個可緩存的線程池。如果線程池的大小超過了處理任務(wù)所需要的線程， 那么就會回收部分空閑（60秒不執(zhí)行任務(wù)）的線程，當任務(wù)數(shù)增加時，此線程池又可以智能的添加新線程來處理任務(wù)。此線程池不會對線程池大小做限制，線程池大小完全依賴于操作系統(tǒng)（或者說JVM）能夠創(chuàng)建的最大線程大小。

newScheduledThreadPool 創(chuàng)建一個大小無限的線程池。此線程池支持定時以及周期性執(zhí)行任務(wù)的需求。

| 實例：

一般情況下，掌握上述幾種線程池就可以了，特殊場景下要自定義一個線程池的除外。舉個簡單例子：

public class ExecutorTest {private static void doPrint(ExecutorService threadPool) {for (int i = 1; i <= 5; i++) {final int taskID = i;threadPool.submit(new Runnable() {@Overridepublic void run() {for (int i = 1; i <= 5; i++) {try {Thread.sleep(20);// 為了測試出效果，讓每次任務(wù)執(zhí)行都需要一定時間} catch (InterruptedException e) {e.printStackTrace();}System.out.println("第" + taskID + "次任務(wù)的第" + i + "次執(zhí)行");}}});}threadPool.shutdown();// 任務(wù)執(zhí)行完畢，關(guān)閉線程池}public static void main(String[] args) {// 創(chuàng)建可以容納3個線程的線程池ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);// 線程池的大小會根據(jù)執(zhí)行的任務(wù)數(shù)動態(tài)分配ExecutorService cachedThreadPool = Executors.newCachedThreadPool();// 創(chuàng)建單個線程的線程池，如果當前線程在執(zhí)行任務(wù)時突然中斷，則會創(chuàng)建一個新的線程替代它繼續(xù)執(zhí)行任務(wù)ExecutorService singleThreadPool = Executors.newSingleThreadExecutor();// 效果類似于Timer定時器ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);// doPrint(fixedThreadPool); // doPrint(cachedThreadPool); // doPrint(singleThreadPool);doPrint(scheduledThreadPool);} }

堅持原創(chuàng)技術(shù)分享，您的支持將鼓勵我繼續(xù)創(chuàng)作！

轉(zhuǎn)載于:https://my.oschina.net/Gxhpro/blog/850643

《新程序員》：云原生和全面數(shù)字化實踐50位技術(shù)專家共同創(chuàng)作，文字、視頻、音頻交互閱讀

總結(jié)

以上是生活随笔為你收集整理的掌握JAVA多线程的利器-线程池的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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