溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

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

發(fā)布時間:2021-06-21 10:51:32 來源:億速云 閱讀:351 作者:小新 欄目:開發(fā)技術(shù)

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

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é)果:

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

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

定長線程池的大小最好根據(jù)系統(tǒng)資源進(jìn)行設(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)思路

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

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

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

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

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

向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI