線程池之newFixedThreadPool定長線程池的實例

Posted on by

newFixedThreadPool定長線程池的實例

newFixedThreadPool

創建一個定長線程池，可控制線程最大並發數，超出的線程會在隊列中等待。newFixedThreadPool固定線程池， 使用完畢必須手動關閉線程池， 否則會一直在內存中存在。

示例代碼：

public class ThreadPoolFixed {
 public static void main(String[] args) {
  //設置線程池大小為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+"當前線程"+Thread.currentThread().getName());
      Thread.sleep(2000);
     } catch (InterruptedException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
     }
    }
   });
  }
  fixedThreadPool.shutdown();
 }
}

運行結果：

因為線程池大小為3，每個任務輸出index後sleep 2秒，所以每兩秒打印3個數字。

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

corePoolSize：

線程池的基本大小，即在沒有任務需要執行的時候線程池的大小，並且隻有在工作隊列滿瞭的情況下才會創建超出這個數量的線程。

這裡需要註意的是：在剛剛創建ThreadPoolExecutor的時候，線程並不會立即啟動，而是要等到有任務提交時才會啟動，除非調用瞭prestartCoreThread/prestartAllCoreThreads事先啟動核心線程。

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

maximumPoolSize：

線程池中允許的最大線程數，線程池中的當前線程數目不會超過該值。

如果隊列中任務已滿，並且當前線程個數小於maximumPoolSize，那麼會創建新的線程來執行任務。

這裡值得一提的是largestPoolSize，該變量記錄瞭線程池在整個生命周期中曾經出現的最大線程個數。

為什麼說是曾經呢？因為線程池創建之後，可以調用setMaximumPoolSize()改變運行的最大線程的數目。

poolSize：

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

定長線程池簡易原理圖及實現思路

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

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

當然，這個線程是是定長的。有些情況下，定長的數量不夠，或者高峰期過後，長度需要降下來。這時候，就需要變長的線程池瞭。後續繼續更新支持動態擴展的線程池的實現思路。

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

推薦閱讀：