線程池之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+"當前線程"+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ù),線程池中的當前線程數(shù)目不會超過該值。
如果隊列中任務(wù)已滿,并且當前線程個數(shù)小于maximumPoolSize,那么會創(chuàng)建新的線程來執(zhí)行任務(wù)。
這里值得一提的是largestPoolSize,該變量記錄了線程池在整個生命周期中曾經(jīng)出現(xiàn)的最大線程個數(shù)。
為什么說是曾經(jīng)呢?因為線程池創(chuàng)建之后,可以調(diào)用setMaximumPoolSize()改變運行的最大線程的數(shù)目。
poolSize:
線程池中當前線程的數(shù)量,當該值為0的時候,意味著沒有任何線程,線程池會終止;同一時刻,poolSize不會超過maximumPoolSize。
定長線程池簡易原理圖及實現(xiàn)思路
隊列中存放著實現(xiàn)了runnable接口的對象。每次有新任務(wù)的時候,就會往隊列中push進一個對象。線程1-4需要定義為繼承了Tread類的內(nèi)部,在類中的run方法中,定一個while循環(huán),不斷的輪詢送隊列中取對象,執(zhí)行對象中的run方法。
線程中需要存放著線程池的對象的指針,便于獲取到線程池對象的隊列。
當然,這個線程是是定長的。有些情況下,定長的數(shù)量不夠,或者高峰期過后,長度需要降下來。這時候,就需要變長的線程池了。后續(xù)繼續(xù)更新支持動態(tài)擴展的線程池的實現(xiàn)思路。
以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關(guān)文章
使用maven profile指定配置文件打包適用多環(huán)境的方法
這篇文章主要介紹了使用maven profile指定配置文件打包適用多環(huán)境的方法,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2018-08-08Jrebel License Server 激活 IDEA-Jrebel-在線-
這篇文章主要介紹了Jrebel License Server 激活 IDEA-Jrebel-在線-離線-均適用,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-12-12Spring?myBatis數(shù)據(jù)庫連接異常問題及解決
這篇文章主要介紹了Spring?myBatis數(shù)據(jù)庫連接異常問題及解決,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2022-06-06Java中使用fileupload組件實現(xiàn)文件上傳功能的實例代碼
這篇文章主要介紹了Java中使用fileupload組件實現(xiàn)文件上傳功能的實例代碼,需要的朋友可以參考下2017-05-05