您好,登錄后才能下訂單哦!
這篇文章主要介紹線程池之newCachedThreadPool可緩存線程池的示例分析,文中介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們一定要看完!
Java通過Executors提供四種線程池,分別為:
newCachedThreadPool創建一個可緩存線程池,如果線程池長度超過處理需要,可靈活回收空閑線程,若無可回收,則新建線程。
newFixedThreadPool 創建一個定長線程池,可控制線程最大并發數,超出的線程會在隊列中等待。
newScheduledThreadPool 創建一個定長線程池,支持定時及周期性任務執行。
newSingleThreadExecutor 創建一個單線程化的線程池,它只會用唯一的工作線程來執行任務,保證所有任務按照指定順序(FIFO, LIFO, 優先級)執行。
這種類型的線程池特點是:
工作線程的創建數量幾乎沒有限制(其實也有限制的,數目為Interger. MAX_VALUE), 這樣可靈活的往線程池中添加線程。
如果長時間沒有往線程池中提交任務,即如果工作線程空閑了指定的時間(默認為1分鐘),則該工作線程將自動終止。終止后,如果你又提交了新的任務,則線程池重新創建一個工作線程。
在使用CachedThreadPool時,一定要注意控制任務的數量,否則,由于大量線程同時運行,很有會造成系統癱瘓。
public class ThreadPoolCached { public static void main(String[] args) { ExecutorService cachedThreadPool = Executors.newCachedThreadPool(); for (int i = 0; i < 10; i++) { final int index = i; try { Thread.sleep(index * 100); } catch (Exception e) { e.printStackTrace(); } cachedThreadPool.execute(new Runnable() { @Override public void run() { System.out.println(index+"當前線程"+Thread.currentThread().getName()); } }); } } }
執行結果:
發現10個線程都是使用的線程1,線程池為無限大,當執行第二個任務時第一個任務已經完成,會復用執行第一個任務的線程,而不用每次新建線程。
先上源碼
public static ExecutorService newCachedThreadPool() { return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()); }
特點:
1.核心線程數為零
2.最大線程數為無限
3.無任務時,線程存活的最大時間為60s
4.任務隊列為同步移交隊列,該隊列沒有緩沖區,即不會有任務會在該隊列中排隊,每當有任務要入隊時,隊列都會將任務移交給一個可用的線程
為什么叫緩存線程池,類比于redis緩存:
前者緩存的是頻繁要用到的線程;后者緩存的是頻繁要用到的數據
前者通過緩存線程,避免了每次執行任務都要創建、銷毀線程的開銷;后者通過緩存數據,避免了每次用到數據都要操作db
兩者都有緩存失效的時間,前者對應keepAliveTime參數,超過該參數對應的時間后,銷毀線程;后者當緩存對應的真實數據被修改時,緩存失效,清除數據
為了盡量重復利用緩存的線程,而不是每次要執行任務時創建新的線程,應盡量使執行任務的時間小于keepAliveTime參數,默認是60s
因為是一個“緩存”線程池,沒有緩存可以永久有效,因此核心線程數為0。因此任務隊列的緩沖區應為空,否則即便系統有可用的線程資源,當有新的任務時也不會被執行,而是進入任務隊列排隊直至隊列滿,這顯然是不合理的。同樣由于隊列緩沖區為空,每來一個任務時,都會在必要時新建線程執行任務,這就有可能導致大量的線程被創建,進而系統癱瘓
以上是“線程池之newCachedThreadPool可緩存線程池的示例分析”這篇文章的所有內容,感謝各位的閱讀!希望分享的內容對大家有幫助,更多相關知識,歡迎關注億速云行業資訊頻道!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。