java線程池：

Java通過Executors提供四種線程池，分別為：

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

newFixedThreadPool 創(chuàng)建一個定長線程池，可控制線程最大并發(fā)數(shù)，超出的線程會在隊列中等待。

newScheduledThreadPool 創(chuàng)建一個定長線程池，支持定時及周期性任務(wù)執(zhí)行。

newSingleThreadExecutor 創(chuàng)建一個單線程化的線程池，它只會用唯一的工作線程來執(zhí)行任務(wù)，保證所有任務(wù)按照指定順序(FIFO, LIFO, 優(yōu)先級)執(zhí)行。

下面我們來分析newCachedThreadPool：

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

工作線程的創(chuàng)建數(shù)量幾乎沒有限制(其實也有限制的,數(shù)目為Interger. MAX_VALUE), 這樣可靈活的往線程池中添加線程。

如果長時間沒有往線程池中提交任務(wù)，即如果工作線程空閑了指定的時間(默認為1分鐘)，則該工作線程將自動終止。終止后，如果你又提交了新的任務(wù)，則線程池重新創(chuàng)建一個工作線程。

在使用CachedThreadPool時，一定要注意控制任務(wù)的數(shù)量，否則，由于大量線程同時運行，很有會造成系統(tǒng)癱瘓。

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+"當(dāng)前線程"+Thread.currentThread().getName());
    }
   });
  }
 }
 }

執(zhí)行結(jié)果：

發(fā)現(xiàn)10個線程都是使用的線程1，線程池為無限大，當(dāng)執(zhí)行第二個任務(wù)時第一個任務(wù)已經(jīng)完成，會復(fù)用執(zhí)行第一個任務(wù)的線程，而不用每次新建線程。

newCachedThreadPool個人理解

先上源碼

    public static ExecutorService newCachedThreadPool() {
        return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                      60L, TimeUnit.SECONDS,
                                      new SynchronousQueue<Runnable>());
    }

特點：

1.核心線程數(shù)為零

2.最大線程數(shù)為無限

3.無任務(wù)時，線程存活的最大時間為60s

4.任務(wù)隊列為同步移交隊列，該隊列沒有緩沖區(qū)，即不會有任務(wù)會在該隊列中排隊，每當(dāng)有任務(wù)要入隊時，隊列都會將任務(wù)移交給一個可用的線程

為什么叫緩存線程池，類比于redis緩存：

前者緩存的是頻繁要用到的線程；后者緩存的是頻繁要用到的數(shù)據(jù)

前者通過緩存線程，避免了每次執(zhí)行任務(wù)都要創(chuàng)建、銷毀線程的開銷；后者通過緩存數(shù)據(jù)，避免了每次用到數(shù)據(jù)都要操作db

兩者都有緩存失效的時間，前者對應(yīng)keepAliveTime參數(shù)，超過該參數(shù)對應(yīng)的時間后，銷毀線程；后者當(dāng)緩存對應(yīng)的真實數(shù)據(jù)被修改時，緩存失效，清除數(shù)據(jù)

為了盡量重復(fù)利用緩存的線程，而不是每次要執(zhí)行任務(wù)時創(chuàng)建新的線程，應(yīng)盡量使執(zhí)行任務(wù)的時間小于keepAliveTime參數(shù)，默認是60s

因為是一個“緩存”線程池，沒有緩存可以永久有效，因此核心線程數(shù)為0。因此任務(wù)隊列的緩沖區(qū)應(yīng)為空，否則即便系統(tǒng)有可用的線程資源，當(dāng)有新的任務(wù)時也不會被執(zhí)行，而是進入任務(wù)隊列排隊直至隊列滿，這顯然是不合理的。同樣由于隊列緩沖區(qū)為空，每來一個任務(wù)時，都會在必要時新建線程執(zhí)行任務(wù)，這就有可能導(dǎo)致大量的線程被創(chuàng)建，進而系統(tǒng)癱瘓

以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。

最新評論