newFixedThreadPool定長(zhǎng)線程池的實(shí)例

newFixedThreadPool

創(chuàng)建一個(gè)定長(zhǎng)線程池，可控制線程最大并發(fā)數(shù)，超出的線程會(huì)在隊(duì)列中等待。newFixedThreadPool固定線程池， 使用完畢必須手動(dòng)關(guān)閉線程池， 否則會(huì)一直在內(nèi)存中存在。

示例代碼：

public class ThreadPoolFixed {
 public static void main(String[] args) {
  //設(shè)置線程池大小為3
  ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);
  for (int i = 0; i < 10; i++) {
   final int index = i;
   fixedThreadPool.execute(new Runnable() {
 
    @Override
    public void run() {
     try {
      System.out.println(index+"當(dāng)前線程"+Thread.currentThread().getName());
      Thread.sleep(2000);
     } catch (InterruptedException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
     }
    }
   });
  }
  fixedThreadPool.shutdown();
 }
}

運(yùn)行結(jié)果：

因?yàn)榫€程池大小為3，每個(gè)任務(wù)輸出index后sleep 2秒，所以每?jī)擅氪蛴?個(gè)數(shù)字。

定長(zhǎng)線程池的大小最好根據(jù)系統(tǒng)資源進(jìn)行設(shè)置。如Runtime.getRuntime().availableProcessors()。

corePoolSize：

線程池的基本大小，即在沒(méi)有任務(wù)需要執(zhí)行的時(shí)候線程池的大小，并且只有在工作隊(duì)列滿了的情況下才會(huì)創(chuàng)建超出這個(gè)數(shù)量的線程。

這里需要注意的是：在剛剛創(chuàng)建ThreadPoolExecutor的時(shí)候，線程并不會(huì)立即啟動(dòng)，而是要等到有任務(wù)提交時(shí)才會(huì)啟動(dòng)，除非調(diào)用了prestartCoreThread/prestartAllCoreThreads事先啟動(dòng)核心線程。

再考慮到keepAliveTime和allowCoreThreadTimeOut超時(shí)參數(shù)的影響，所以沒(méi)有任務(wù)需要執(zhí)行的時(shí)候，線程池的大小不一定是corePoolSize。

maximumPoolSize：

線程池中允許的最大線程數(shù)，線程池中的當(dāng)前線程數(shù)目不會(huì)超過(guò)該值。

如果隊(duì)列中任務(wù)已滿，并且當(dāng)前線程個(gè)數(shù)小于maximumPoolSize，那么會(huì)創(chuàng)建新的線程來(lái)執(zhí)行任務(wù)。

這里值得一提的是largestPoolSize，該變量記錄了線程池在整個(gè)生命周期中曾經(jīng)出現(xiàn)的最大線程個(gè)數(shù)。

為什么說(shuō)是曾經(jīng)呢？因?yàn)榫€程池創(chuàng)建之后，可以調(diào)用setMaximumPoolSize()改變運(yùn)行的最大線程的數(shù)目。

poolSize：

線程池中當(dāng)前線程的數(shù)量，當(dāng)該值為0的時(shí)候，意味著沒(méi)有任何線程，線程池會(huì)終止；同一時(shí)刻，poolSize不會(huì)超過(guò)maximumPoolSize。

定長(zhǎng)線程池簡(jiǎn)易原理圖及實(shí)現(xiàn)思路

隊(duì)列中存放著實(shí)現(xiàn)了runnable接口的對(duì)象。每次有新任務(wù)的時(shí)候，就會(huì)往隊(duì)列中push進(jìn)一個(gè)對(duì)象。線程1-4需要定義為繼承了Tread類的內(nèi)部，在類中的run方法中，定一個(gè)while循環(huán)，不斷的輪詢送隊(duì)列中取對(duì)象，執(zhí)行對(duì)象中的run方法。

線程中需要存放著線程池的對(duì)象的指針，便于獲取到線程池對(duì)象的隊(duì)列。

當(dāng)然，這個(gè)線程是是定長(zhǎng)的。有些情況下，定長(zhǎng)的數(shù)量不夠，或者高峰期過(guò)后，長(zhǎng)度需要降下來(lái)。這時(shí)候，就需要變長(zhǎng)的線程池了。后續(xù)繼續(xù)更新支持動(dòng)態(tài)擴(kuò)展的線程池的實(shí)現(xiàn)思路。

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

最新評(píng)論