Java中的線程池如何實現(xiàn)線程復用
Java線程池實現(xiàn)線程復用
閑來沒事突然想到這個問題,便百度了下想查看具體實現(xiàn),無果。
便自己翻看了下源碼
以下是分析過程
眾所周知,Java內部自帶了個線程池實現(xiàn) ExecutorService (雖然一直被人看不起)。
隨便找到其中的一個靜態(tài)方法
public static ExecutorService newFixedThreadPool(int nThreads) { return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()); }
可知 ExecutorService 也只是一個封裝,真正的實現(xiàn)還得看 ThreadPoolExecutor。
根據(jù)推斷我們可以首先從 `ThreadPoolExecutor#execute` 找起
public void execute(Runnable command) { if (command == null) throw new NullPointerException(); int c = ctl.get(); if (workerCountOf(c) < corePoolSize) { if (addWorker(command, true)) return; c = ctl.get(); } if (isRunning(c) && workQueue.offer(command)) { int recheck = ctl.get(); if (! isRunning(recheck) && remove(command)) reject(command); else if (workerCountOf(recheck) == 0) addWorker(null, false); } else if (!addWorker(command, false)) reject(command); }
讀題解
傳入的 Runnable 實例最終經(jīng)過一系列安全檢驗被傳入 addWorker 方法中
繼續(xù)追蹤可以看到實例(firstTask) 被傳入 `ThreadPoolLocal#Worker#init` 的有參構造器中
而該 Worker 實例被添加進名為 workers 的哈希表中
終于是找到正主了!
讓我們看看這個 Worker 到底是何方神圣,究竟是如何實現(xiàn)線程復用!
private final class Worker extends AbstractQueuedSynchronizer implements Runnable { public void run() { runWorker(this); } }
好家伙,原來 Worker 也實現(xiàn)了 Runnable,查看 runWorker 方法可知,當當前任務執(zhí)行后task置空,Worker 線程調用 getTask 方法從任務隊列中獲取新任務并執(zhí)行。
至此便實現(xiàn)了一個 Worker 線程執(zhí)行多個 Runnable 任務的功能。
總結
以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關文章
Java guava monitor監(jiān)視器線程的使用詳解
工作中的場景中是否存在類似這樣的場景,需要提交的線程在某個觸發(fā)條件下執(zhí)行。本文主要就是使用guava中的monitor來優(yōu)雅的實現(xiàn)帶監(jiān)視器的線程2021-11-11Spring Security如何使用URL地址進行權限控制
這篇文章主要介紹了Spring Security如何使用URL地址進行權限控制,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-12-12StringUtils,CollectionUtils判斷為空的方法和原生代碼哪個效率最高
這篇文章主要介紹了StringUtils,CollectionUtils判斷為空的方法和原生代碼哪個效率最高,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2022-02-02