Java之ThreadPoolExecutor類(lèi)詳解

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

這篇文章主要介紹了Java之ThreadPoolExecutor類(lèi)詳解,本篇文章通過(guò)簡(jiǎn)要的案例,講解了該項(xiàng)技術(shù)的了解與使用,以下就是詳細(xì)內(nèi)容,需要的朋友可以參考下

ThreadPoolExecutor

ThreadPoolExecutor是線程池框架的一個(gè)核心類(lèi)，線程池通過(guò)線程復(fù)用機(jī)制，并對(duì)線程進(jìn)行統(tǒng)一管理

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

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

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

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

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

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

3.keepAliveTime

線程空閑時(shí)的存活時(shí)間。默認(rèn)情況下，只有當(dāng)線程池中的線程數(shù)大于corePoolSize時(shí)，keepAliveTime才會(huì)起作用，如果一個(gè)線程空閑的時(shí)間達(dá)到keepAliveTime，則會(huì)終止，直到線程池中的線程數(shù)不超過(guò)corePoolSize。但是如果調(diào)用了allowCoreThreadTimeOut(boolean)方法，keepAliveTime參數(shù)也會(huì)起作用，直到線程池中的線程數(shù)為 0。

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

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

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

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

AbortPolicy：丟棄任務(wù)并拋出RejectedExecutionException異常，默認(rèn)策略；
CallerRunsPolicy：由調(diào)用execute方法的線程執(zhí)行該任務(wù)；
DiscardPolicy：丟棄任務(wù)，但是不拋出異常;
DiscardOldestPolicy：丟棄阻塞隊(duì)列前面的任務(wù)，然后重新嘗試執(zhí)行任務(wù)（重復(fù)此過(guò)程）。
當(dāng)然也可以根據(jù)應(yīng)用場(chǎng)景實(shí)現(xiàn)RejectedExecutionHandler接口自定義飽和策略，如記錄日志或持久化存儲(chǔ)不能處理的任務(wù)。

到此這篇關(guān)于Java之ThreadPoolExecutor類(lèi)詳解的文章就介紹到這了,更多相關(guān)Java之ThreadPoolExecutor內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: