java線程池：

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

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

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

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

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

下面我們來分析newCachedThreadPool：

這種類型的線程池特點(diǎn)是：

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

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

在使用CachedThreadPool時(shí)，一定要注意控制任務(wù)的數(shù)量，否則，由于大量線程同時(shí)運(yùn)行，很有會(huì)造成系統(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個(gè)線程都是使用的線程1，線程池為無限大，當(dāng)執(zhí)行第二個(gè)任務(wù)時(shí)第一個(gè)任務(wù)已經(jīng)完成，會(huì)復(fù)用執(zhí)行第一個(gè)任務(wù)的線程，而不用每次新建線程。

newCachedThreadPool個(gè)人理解

先上源碼

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

特點(diǎn)：

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

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

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

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

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

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

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

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

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

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

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

最新評(píng)論