Java之ThreadPoolExecutor類詳解

更新時間：2021年08月02日 08:49:27 作者：一只可愛的小狐貍

這篇文章主要介紹了Java之ThreadPoolExecutor類詳解,本篇文章通過簡要的案例,講解了該項技術的了解與使用,以下就是詳細內容,需要的朋友可以參考下

ThreadPoolExecutor

ThreadPoolExecutor是線程池框架的一個核心類，線程池通過線程復用機制，并對線程進行統(tǒng)一管理

降低系統(tǒng)資源消耗。通過復用已存在的線程，降低線程創(chuàng)建和銷毀造成的消耗；
提高響應速度。當有任務到達時，無需等待新線程的創(chuàng)建便能立即執(zhí)行；
提高線程的可管理性。線程是稀缺資源，如果無限制的創(chuàng)建，不僅會消耗大量系統(tǒng)資源，還會降低系統(tǒng)的穩(wěn) 定性，使用線程池可以進行對線程進行統(tǒng)一的分配、調優(yōu)和監(jiān)控。

線程池的運行狀態(tài)總共有5種，其值和含義分別如下：

RUNNING: 高3位為111，接受新任務并處理阻塞隊列中的任務
SHUTDOWN: 高3位為000，不接受新任務但會處理阻塞隊列中的任務
STOP:高3位為001，不會接受新任務，也不會處理阻塞隊列中的任務，并且中斷正在運行的任務
TIDYING: 高3位為010，所有任務都已終止，工作線程數(shù)量為0，線程池將轉化到TIDYING狀態(tài)，即將要執(zhí)行 terminated()結束鉤子方法
TERMINATED: 高3位為011，terminated()方法已經執(zhí)行結束

構造器中各個參數(shù)的含義：

1.corePoolSize
線程池中的核心線程數(shù)。當提交一個任務時，線程池創(chuàng)建一個新線程執(zhí)行任務，直到當前線程數(shù)等于 corePoolSize；如果當前線程數(shù)為corePoolSize，繼續(xù)提交的任務被保存到阻塞隊列中，等待被執(zhí)行。

2.maximumPoolSize
線程池中允許的大線程數(shù)。如果當前阻塞隊列滿了，且繼續(xù)提交任務，則創(chuàng)建新的線程執(zhí)行任務，前提是當前線程數(shù)小于maximumPoolSize。

3.keepAliveTime

線程空閑時的存活時間。默認情況下，只有當線程池中的線程數(shù)大于corePoolSize時，keepAliveTime才會起作用，如果一個線程空閑的時間達到keepAliveTime，則會終止，直到線程池中的線程數(shù)不超過corePoolSize。但是如果調用了allowCoreThreadTimeOut(boolean)方法，keepAliveTime參數(shù)也會起作用，直到線程池中的線程數(shù)為 0。

4.unit
keepAliveTime參數(shù)的時間單位。

5.workQueue
任務緩存隊列，用來存放等待執(zhí)行的任務。如果當前線程數(shù)為corePoolSize，繼續(xù)提交的任務就會被保存到任務緩存隊列中，等待被執(zhí)行。
一般來說，這里的BlockingQueue有以下三種選擇：
SynchronousQueue：一個不存儲元素的阻塞隊列，每個插入操作必須等到另一個線程調用移除操作，否則插入操作一直處于阻塞狀態(tài)。因此，如果線程池中始終沒有空閑線程（任務提交的平均速度快于被處理的速度），可能出現(xiàn)無限制的線程增長。 LinkedBlockingQueue：基于鏈表結構的阻塞隊列，如果不設置初始化容量，其容量Integer.MAX_VALUE，即為無界隊列。因此，如果線程池中線程數(shù)達到了corePoolSize，且始終沒有空閑線程（任務提交的平均速度快于被處理的速度），任務緩存隊列可能出現(xiàn)無限制的增長。 ArrayBlockingQueue：基于數(shù)組結構的有界阻塞隊列，按FIFO排序任務。

6.threadFactory
線程工廠，創(chuàng)建新線程時使用的線程工廠。

7.handler
任務拒絕策略，當阻塞隊列滿了，且線程池中的線程數(shù)達到maximumPoolSize，如果繼續(xù)提交任務，就會采取任務拒絕策略處理該任務，線程池提供了4種任務拒絕策略：