線程池之newCachedThreadPool可緩存線程池的實例
java線程池:
Java通過Executors提供四種線程池,分別為:
newCachedThreadPool創(chuàng)建一個可緩存線程池,如果線程池長度超過處理需要,可靈活回收空閑線程,若無可回收,則新建線程。
newFixedThreadPool 創(chuàng)建一個定長線程池,可控制線程最大并發(fā)數,超出的線程會在隊列中等待。
newScheduledThreadPool 創(chuàng)建一個定長線程池,支持定時及周期性任務執(zhí)行。
newSingleThreadExecutor 創(chuàng)建一個單線程化的線程池,它只會用唯一的工作線程來執(zhí)行任務,保證所有任務按照指定順序(FIFO, LIFO, 優(yōu)先級)執(zhí)行。
下面我們來分析newCachedThreadPool:
這種類型的線程池特點是:
工作線程的創(chuàng)建數量幾乎沒有限制(其實也有限制的,數目為Interger. MAX_VALUE), 這樣可靈活的往線程池中添加線程。
如果長時間沒有往線程池中提交任務,即如果工作線程空閑了指定的時間(默認為1分鐘),則該工作線程將自動終止。終止后,如果你又提交了新的任務,則線程池重新創(chuàng)建一個工作線程。
在使用CachedThreadPool時,一定要注意控制任務的數量,否則,由于大量線程同時運行,很有會造成系統(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+"當前線程"+Thread.currentThread().getName());
}
});
}
}
}
執(zhí)行結果:

發(fā)現10個線程都是使用的線程1,線程池為無限大,當執(zhí)行第二個任務時第一個任務已經完成,會復用執(zhí)行第一個任務的線程,而不用每次新建線程。
newCachedThreadPool個人理解
先上源碼
public static ExecutorService newCachedThreadPool() {
return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
60L, TimeUnit.SECONDS,
new SynchronousQueue<Runnable>());
}
特點:
1.核心線程數為零
2.最大線程數為無限
3.無任務時,線程存活的最大時間為60s
4.任務隊列為同步移交隊列,該隊列沒有緩沖區(qū),即不會有任務會在該隊列中排隊,每當有任務要入隊時,隊列都會將任務移交給一個可用的線程
為什么叫緩存線程池,類比于redis緩存:
前者緩存的是頻繁要用到的線程;后者緩存的是頻繁要用到的數據
前者通過緩存線程,避免了每次執(zhí)行任務都要創(chuàng)建、銷毀線程的開銷;后者通過緩存數據,避免了每次用到數據都要操作db
兩者都有緩存失效的時間,前者對應keepAliveTime參數,超過該參數對應的時間后,銷毀線程;后者當緩存對應的真實數據被修改時,緩存失效,清除數據
為了盡量重復利用緩存的線程,而不是每次要執(zhí)行任務時創(chuàng)建新的線程,應盡量使執(zhí)行任務的時間小于keepAliveTime參數,默認是60s
因為是一個“緩存”線程池,沒有緩存可以永久有效,因此核心線程數為0。因此任務隊列的緩沖區(qū)應為空,否則即便系統(tǒng)有可用的線程資源,當有新的任務時也不會被執(zhí)行,而是進入任務隊列排隊直至隊列滿,這顯然是不合理的。同樣由于隊列緩沖區(qū)為空,每來一個任務時,都會在必要時新建線程執(zhí)行任務,這就有可能導致大量的線程被創(chuàng)建,進而系統(tǒng)癱瘓
以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關文章
SpringCloud Eureka服務的基本配置和操作方法
Eureka是Netflix開源的一個基于REST的服務治理框架,主要用于實現微服務架構中的服務注冊與發(fā)現,Eureka是Netflix開源的服務發(fā)現框架,用于在分布式系統(tǒng)中實現服務的自動注冊與發(fā)現,本文介紹SpringCloud Eureka服務的基本配置和操作方法,感興趣的朋友一起看看吧2023-12-12
SpringBoot返回統(tǒng)一的JSON標準格式實現步驟
這篇文章主要介紹了SpringBoot返回統(tǒng)一的JSON標準格式,本文通過實例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-08-08
Java中List Set和Map之間的區(qū)別_動力節(jié)點Java學院整理
Java集合的主要分為三種類型set集,list列表,map映射,接下來通過本文給大家詳細介紹java中l(wèi)ist、Set和Map之間的區(qū)別,需要的的朋友參考下吧2017-05-05

