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.