線程池之newFixedThreadPool定長線程池的示例分析

這篇文章將為大家詳細講解有關線程池之newFixedThreadPool定長線程池的示例分析，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。

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方法。

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

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

關于“線程池之newFixedThreadPool定長線程池的示例分析”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，使各位可以學到更多知識，如果覺得文章不錯，請把它分享出去讓更多的人看到。