中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

線程池之newCachedThreadPool可緩存線程池的示例分析

發布時間:2021-06-21 10:51:57 來源:億速云 閱讀:553 作者:小新 欄目:開發技術

這篇文章主要介紹線程池之newCachedThreadPool可緩存線程池的示例分析,文中介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們一定要看完!

java線程池:

Java通過Executors提供四種線程池,分別為:

newCachedThreadPool創建一個可緩存線程池,如果線程池長度超過處理需要,可靈活回收空閑線程,若無可回收,則新建線程。

newFixedThreadPool 創建一個定長線程池,可控制線程最大并發數,超出的線程會在隊列中等待。

newScheduledThreadPool 創建一個定長線程池,支持定時及周期性任務執行。

newSingleThreadExecutor 創建一個單線程化的線程池,它只會用唯一的工作線程來執行任務,保證所有任務按照指定順序(FIFO, LIFO, 優先級)執行。

下面我們來分析newCachedThreadPool:

這種類型的線程池特點是:

工作線程的創建數量幾乎沒有限制(其實也有限制的,數目為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());
    }
   });
  }
 }
 }

執行結果:

線程池之newCachedThreadPool可緩存線程池的示例分析

發現10個線程都是使用的線程1,線程池為無限大,當執行第二個任務時第一個任務已經完成,會復用執行第一個任務的線程,而不用每次新建線程。

newCachedThreadPool個人理解

先上源碼

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可緩存線程池的示例分析”這篇文章的所有內容,感謝各位的閱讀!希望分享的內容對大家有幫助,更多相關知識,歡迎關注億速云行業資訊頻道!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

海兴县| 凉山| 思茅市| 家居| 师宗县| 中卫市| 澳门| 温宿县| 呼玛县| 祥云县| 高碑店市| 蓬溪县| 芮城县| 常熟市| 海阳市| 嘉祥县| 登封市| 石门县| 大竹县| 海口市| 贺州市| 汶上县| 扬中市| 新巴尔虎右旗| 滕州市| 大连市| 西和县| 安岳县| 商河县| 额济纳旗| 清苑县| 夏津县| 时尚| 新乡县| 灵台县| 万安县| 华宁县| 左权县| 北流市| 大关县| 称多县|