線程池之newCachedThreadPool可緩存線程池的實例

Posted on by

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());
    }
   });
  }
 }
 }

執行結果：

發現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。因此任務隊列的緩沖區應為空，否則即便系統有可用的線程資源，當有新的任務時也不會被執行，而是進入任務隊列排隊直至隊列滿，這顯然是不合理的。同樣由於隊列緩沖區為空，每來一個任務時，都會在必要時新建線程執行任務，這就有可能導致大量的線程被創建，進而系統癱瘓

以上為個人經驗，希望能給大傢一個參考，也希望大傢多多支持WalkonNet。

推薦閱讀：