10:Java中的線程池

1:java中的線程池實(shí)現(xiàn)原理

2:上圖中的任務(wù)隊(duì)列(用于保存等待執(zhí)行的任務(wù)的阻塞隊(duì)列)介紹

(1)ArrayBlockingQueue:基于數(shù)組結(jié)構(gòu)的有界阻塞隊(duì)列,按照FIFO(先進(jìn)先出)原則對(duì)元素進(jìn)行排序。

(2)LinkedBlockingQueue:基于鏈表的阻塞隊(duì)列,按照FIFO排序元素,吞吐量通常高于ArrayBlockingQueue.

靜態(tài)工廠Executors.newFixedThreadPool()使用了它。

(3)SynchronousQueue:一個(gè)不存儲(chǔ)元素的阻塞隊(duì)列。每個(gè)插入操作必須等到另一個(gè)線程調(diào)用了移除操作,否則插入一直處于阻塞。吞吐量高于LinkedBlockingQueue。Executors.newCachedThreadPool使用了該隊(duì)列。

(4)PriorityBlockingQueue:一個(gè)具有優(yōu)先級(jí)的無(wú)限阻塞隊(duì)列。

3:上圖中飽和策略(RehectedExecutionHandler)介紹

(1)AbortPolicy:直接拋出異常。

(2)CallerRunsPolicy:只用調(diào)用者所在線程來(lái)運(yùn)行任務(wù)。

(3)DiscardOldestPolicy:丟棄隊(duì)列里最近的一個(gè)任務(wù),并執(zhí)行當(dāng)前任務(wù)。

(4)DiscardPolicy:不處理,丟棄了。

注意:也可以實(shí)現(xiàn)RejectedExecutionHandle接口自定義策略。比如:記錄日志或持久化存儲(chǔ)不能處理的任務(wù)。

4:向線程池提交任務(wù)

兩種方法:

(1)execute():用于提交不需要返回值的的任務(wù),無(wú)法判斷任務(wù)是否被線程池執(zhí)行成功。

(2)submit():用于提交需要返回值的任務(wù)。線程池返回一個(gè)future類型的對(duì)象。需要注意:調(diào)用future對(duì)象的get()方法會(huì)阻塞當(dāng)前線程直到任務(wù)完成。而使用get(long timeout , TimeUnit unit)方法則會(huì)阻塞當(dāng)前線程一段時(shí)間后立即返回,這時(shí)候可能任務(wù)沒(méi)有執(zhí)行完。

5:關(guān)閉線程池

原理:遍歷線程池中的工作線程,然后逐個(gè)調(diào)用線程的interrupt方法來(lái)中斷線程。

(1)shutdown():將線程池狀態(tài)設(shè)置為SHUTDOWN狀態(tài),然后中斷所有沒(méi)有正在執(zhí)行任務(wù)的線程。

(2)shutdownNow():將線程池狀態(tài)設(shè)置為STOP,然后嘗試停止所有的正在執(zhí)行或暫停任務(wù)的線程。

注意:調(diào)用了2個(gè)方法中的任意一個(gè),isShutdown方法就會(huì)返回true。當(dāng)所有的任務(wù)都關(guān)閉以后,才表示線程池關(guān)閉成功,這時(shí)候調(diào)用isTerminaed方法會(huì)返回true.

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書(shū)系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容