您好,登錄后才能下訂單哦!
這篇文章主要介紹線程池之newCachedThreadPool可緩存線程池的示例分析,文中介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們一定要看完!
Java通過(guò)Executors提供四種線程池,分別為:
newCachedThreadPool創(chuàng)建一個(gè)可緩存線程池,如果線程池長(zhǎng)度超過(guò)處理需要,可靈活回收空閑線程,若無(wú)可回收,則新建線程。
newFixedThreadPool 創(chuàng)建一個(gè)定長(zhǎng)線程池,可控制線程最大并發(fā)數(shù),超出的線程會(huì)在隊(duì)列中等待。
newScheduledThreadPool 創(chuàng)建一個(gè)定長(zhǎng)線程池,支持定時(shí)及周期性任務(wù)執(zhí)行。
newSingleThreadExecutor 創(chuàng)建一個(gè)單線程化的線程池,它只會(huì)用唯一的工作線程來(lái)執(zhí)行任務(wù),保證所有任務(wù)按照指定順序(FIFO, LIFO, 優(yōu)先級(jí))執(zhí)行。
這種類(lèi)型的線程池特點(diǎn)是:
工作線程的創(chuàng)建數(shù)量幾乎沒(méi)有限制(其實(shí)也有限制的,數(shù)目為Interger. MAX_VALUE), 這樣可靈活的往線程池中添加線程。
如果長(zhǎng)時(shí)間沒(méi)有往線程池中提交任務(wù),即如果工作線程空閑了指定的時(shí)間(默認(rèn)為1分鐘),則該工作線程將自動(dòng)終止。終止后,如果你又提交了新的任務(wù),則線程池重新創(chuàng)建一個(gè)工作線程。
在使用CachedThreadPool時(shí),一定要注意控制任務(wù)的數(shù)量,否則,由于大量線程同時(shí)運(yùn)行,很有會(huì)造成系統(tǒng)癱瘓。
public class ThreadPoolCached { public static void main(String[] args) { ExecutorService cachedThreadPool = Executors.newCachedThreadPool(); for (int i = 0; i < 10; i++) { final int index = i; try { Thread.sleep(index * 100); } catch (Exception e) { e.printStackTrace(); } cachedThreadPool.execute(new Runnable() { @Override public void run() { System.out.println(index+"當(dāng)前線程"+Thread.currentThread().getName()); } }); } } }
執(zhí)行結(jié)果:
發(fā)現(xiàn)10個(gè)線程都是使用的線程1,線程池為無(wú)限大,當(dāng)執(zhí)行第二個(gè)任務(wù)時(shí)第一個(gè)任務(wù)已經(jīng)完成,會(huì)復(fù)用執(zhí)行第一個(gè)任務(wù)的線程,而不用每次新建線程。
先上源碼
public static ExecutorService newCachedThreadPool() { return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()); }
特點(diǎn):
1.核心線程數(shù)為零
2.最大線程數(shù)為無(wú)限
3.無(wú)任務(wù)時(shí),線程存活的最大時(shí)間為60s
4.任務(wù)隊(duì)列為同步移交隊(duì)列,該隊(duì)列沒(méi)有緩沖區(qū),即不會(huì)有任務(wù)會(huì)在該隊(duì)列中排隊(duì),每當(dāng)有任務(wù)要入隊(duì)時(shí),隊(duì)列都會(huì)將任務(wù)移交給一個(gè)可用的線程
為什么叫緩存線程池,類(lèi)比于redis緩存:
前者緩存的是頻繁要用到的線程;后者緩存的是頻繁要用到的數(shù)據(jù)
前者通過(guò)緩存線程,避免了每次執(zhí)行任務(wù)都要?jiǎng)?chuàng)建、銷(xiāo)毀線程的開(kāi)銷(xiāo);后者通過(guò)緩存數(shù)據(jù),避免了每次用到數(shù)據(jù)都要操作db
兩者都有緩存失效的時(shí)間,前者對(duì)應(yīng)keepAliveTime參數(shù),超過(guò)該參數(shù)對(duì)應(yīng)的時(shí)間后,銷(xiāo)毀線程;后者當(dāng)緩存對(duì)應(yīng)的真實(shí)數(shù)據(jù)被修改時(shí),緩存失效,清除數(shù)據(jù)
為了盡量重復(fù)利用緩存的線程,而不是每次要執(zhí)行任務(wù)時(shí)創(chuàng)建新的線程,應(yīng)盡量使執(zhí)行任務(wù)的時(shí)間小于keepAliveTime參數(shù),默認(rèn)是60s
因?yàn)槭且粋€(gè)“緩存”線程池,沒(méi)有緩存可以永久有效,因此核心線程數(shù)為0。因此任務(wù)隊(duì)列的緩沖區(qū)應(yīng)為空,否則即便系統(tǒng)有可用的線程資源,當(dāng)有新的任務(wù)時(shí)也不會(huì)被執(zhí)行,而是進(jìn)入任務(wù)隊(duì)列排隊(duì)直至隊(duì)列滿(mǎn),這顯然是不合理的。同樣由于隊(duì)列緩沖區(qū)為空,每來(lái)一個(gè)任務(wù)時(shí),都會(huì)在必要時(shí)新建線程執(zhí)行任務(wù),這就有可能導(dǎo)致大量的線程被創(chuàng)建,進(jìn)而系統(tǒng)癱瘓
以上是“線程池之newCachedThreadPool可緩存線程池的示例分析”這篇文章的所有內(nèi)容,感謝各位的閱讀!希望分享的內(nèi)容對(duì)大家有幫助,更多相關(guān)知識(shí),歡迎關(guān)注億速云行業(yè)資訊頻道!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。