newFixedThreadPool定長線程池的實例

newFixedThreadPool

創(chuàng)建一個定長線程池，可控制線程最大并發(fā)數(shù)，超出的線程會在隊列中等待。newFixedThreadPool固定線程池， 使用完畢必須手動關(guān)閉線程池， 否則會一直在內(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();
 }
}

運行結(jié)果：

因為線程池大小為3，每個任務(wù)輸出index后sleep 2秒，所以每兩秒打印3個數(shù)字。

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

corePoolSize：

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

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

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

maximumPoolSize：

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

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

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

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

poolSize：

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

定長線程池簡易原理圖及實現(xiàn)思路

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

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

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

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

最新評論