我們先來了解了解線程池怎么來的,知其所來,方能知其所往,根據摩爾定律所說:集成電路上可容納的晶體管數量每 18 個月翻一番,因此 CPU 上的晶體管數量會越來越多。
但隨著時間的推移,集成電路上可容納的晶體管數量已趨向飽和,摩爾定律也漸漸失效,因此多核 CPU 逐漸變為主流,與之相對應的多線程編程也開始變得普及和流行起來,這當然也是很久之前的事了,對于現在而言多線程編程已經成為程序員必備的職業技能了,那接下來我們就來聊聊“線程池”這個多線程編程中最重要的話題,我們先來講講線程池的概念,然后說他的優點,那么他有什么用你必然也就知道了。
什么是線程池?
線程池(ThreadPool)是一種基于池化思想管理和使用線程的機制。它是將多個線程預先存儲在一個“池子”內,當有任務出現時可以避免重新創建和銷毀線程所帶來性能開銷,只需要從“池子”內取出相應的線程執行對應的任務即可。池化思想在計算機的應用也比較廣泛,比如以下這些:
· 內存池(Memory Pooling):預先申請內存,提升申請內存速度,減少內存碎片。
· 連接池(Connection Pooling):預先申請數據庫連接,提升申請連接的速度,降低系統的開銷。
· 實例池(Object Pooling):循環使用對象,減少資源在初始化和釋放時的昂貴損耗。
線程池的優勢主要體現在以下4點:
1. 降低資源消耗:通過池化技術重復利用已創建的線程,降低線程創建和銷毀造成的損耗。
2. 提高響應速度:任務到達時,無需等待線程創建即可立即執行。
3. 提高線程的可管理性:線程是稀缺資源,如果無限制創建,不僅會消耗系統資源,還會因為線程的不合理分布導致資源調度失衡,降低系統的穩定性。使用線程池可以進行統一的分配、調優和監控。
4. 提供更多更強大的功能:線程池具備可拓展性,允許開發人員向其中增加更多的功能。比如延時定時線程池ScheduledThreadPoolExecutor,就允許任務延期執行或定期執行。
同時我其實建議大家在idea中添加《阿里巴巴java開發手冊》,當然我們也可以下載他電子書看看,其中就寫到,線程資源必須通過線程池提供,不允許在應用中自行顯式創建線程。
說明:線程池的好處是減少在創建和銷毀線程上所消耗的時間以及系統資源的開銷,解決資源不足的問題。如果不使用線程池,有可能造成系統創建大量同類線程而導致消耗完內存或者“過度切換”的問題。
知道了什么是線程池以及為什要用線程池之后,我們再來看怎么用線程池
線程池的創建總共有7種,但總體類說可分為2類:
· 一類是通過 ThreadPoolExecutor 創建的線程池;
· 另一個類是通過 Executors 創建的線程池。
線程池的創建方式總共包含以下 7 種(其中 6 種是通過 Executors 創建的,1 種是通過 ThreadPoolExecutor 創建的):
1. Executors.newFixedThreadPool:創建一個固定大小的線程池,可控制并發的線程數,超出的線程會在隊列中等待;
2. Executors.newCachedThreadPool:創建一個可緩存的線程池,若線程數超過處理所需,緩存一段時間后會回收,若線程數不夠,則新建線程;
3. Executors.newSingleThreadExecutor:創建單個線程數的線程池,它可以保證先進先出的執行順序;
4. Executors.newScheduledThreadPool:創建一個可以執行延遲任務的線程池;
5. Executors.newSingleThreadScheduledExecutor:創建一個單線程的可以執行延遲任務的線程池;
6. Executors.newWorkStealingPool:創建一個搶占式執行的線程池(任務執行順序不確定)【JDK 1.8 添加】。
7. ThreadPoolExecutor:最原始的創建線程池的方式,它包含了 7 個參數可供設置,后面會詳細講。(這個是用的最多的,所以參數真有可能問你哦)
ThreadPoolExecutor 參數介紹:
參數 1:corePoolSize
核心線程數,線程池中始終存活的線程數。
參數 2:maximumPoolSize
最大線程數,線程池中允許的最大線程數,當線程池的任務隊列滿了之后可以創建的最大線程數。
參數 3:keepAliveTime
最大線程數可以存活的時間,當線程中沒有任務執行時,最大線程就會銷毀一部分,最終保持核心線程數量的線程。
參數 4:unit:
單位是和參數 3 存活時間配合使用的,合在一起用于設定線程的存活時間 ,參數 keepAliveTime 的時間單位有以下 7 種可選:
· TimeUnit.DAYS:天
· TimeUnit.HOURS:小時
· TimeUnit.MINUTES:分
· TimeUnit.SECONDS:秒
· TimeUnit.MILLISECONDS:毫秒
· TimeUnit.MICROSECONDS:微妙
· TimeUnit.NANOSECONDS:納秒
參數 5:workQueue
一個阻塞隊列,用來存儲線程池等待執行的任務,均為線程安全,它包含以下 7 種類型:
· ArrayBlockingQueue:一個由數組結構組成的有界阻塞隊列。
· LinkedBlockingQueue:一個由鏈表結構組成的有界阻塞隊列。
· SynchronousQueue:一個不存儲元素的阻塞隊列,即直接提交給線程不保持它們。
· PriorityBlockingQueue:一個支持優先級排序的無界阻塞隊列。
· DelayQueue:一個使用優先級隊列實現的無界阻塞隊列,只有在延遲期滿時才能從中提取元素。
· LinkedTransferQueue:一個由鏈表結構組成的無界阻塞隊列。與SynchronousQueue類似,還含有非阻塞方法。
· LinkedBlockingDeque:一個由鏈表結構組成的雙向阻塞隊列。
較常用的是 LinkedBlockingQueue 和 Synchronous,線程池的排隊策略與 BlockingQueue 有關。
參數 6:threadFactory
線程工廠,主要用來創建線程,默認為正常優先級、非守護線程。
參數 7:handler
拒絕策略,拒絕處理任務時的策略,系統提供了 4 種可選:
· AbortPolicy:拒絕并拋出異常。
· CallerRunsPolicy:使用當前調用的線程來執行此任務。
· DiscardOldestPolicy:拋棄隊列頭部(最舊)的一個任務,并執行當前任務。
· DiscardPolicy:忽略并拋棄當前任務。
默認策略為 AbortPolicy。
我們講講單線程池的意義:
從以上可以看出 newSingleThreadExecutor 和 newSingleThreadScheduledExecutor 創建的都是單線程池,那么單線程池的意義是什么呢?
答:雖然是單線程池,但提供了工作隊列,生命周期管理,工作線程維護等功能。
線程池的執行流程:
ThreadPoolExecutor 關鍵節點的執行流程如下:
· 當線程數小于核心線程數時,創建線程。
· 當線程數大于等于核心線程數,且任務隊列未滿時,將任務放入任務隊列。
· 當線程數大于等于核心線程數,且任務隊列已滿:若線程數小于最大線程數,創建線程;若線程數等于最大線程數,拋出異常,拒絕任務。
線程拒絕策略
我們來演示一下 ThreadPoolExecutor 的拒絕策略的觸發,我們使用 DiscardPolicy 的拒絕策略,它會忽略并拋棄當前任務的策略
自定義拒絕策略:
除了 Java 自身提供的 4 種拒絕策略之外,我們也可以自定義拒絕策略
你該知道,你該懂的知識都懂了吧,是不是選用哪種線程池你心里有答案了,那我來來說說咱們最后這個問題選用問題:
我們來看下阿里巴巴《Java開發手冊》給我們的答案:
【強制要求】線程池不允許使用 Executors 去創建,而是通過 ThreadPoolExecutor 的方式,這樣的處理方式讓寫的同學更加明確線程池的運行規則,規避資源耗盡的風險。
說明:Executors 返回的線程池對象的弊端如下:
1) FixedThreadPool 和 SingleThreadPool:允許的請求隊列長度為 Integer.MAX_VALUE,可能會堆積大量的請求,從而導致 OOM。
2)CachedThreadPool:允許的創建線程數量為 Integer.MAX_VALUE,可能會創建大量的線程,從而導致 OOM。
所以綜上情況所述,我們推薦使用 ThreadPoolExecutor 的方式進行線程池的創建,因為這種創建方式更可控,并且更加明確了線程池的運行規則,可以規避一些未知的風險。
最后多說一句,就一句哈哈,ThreadPoolExecutor 的方式進行線程池的創建,ThreadPoolExecutor 最多可以設置 7 個參數,當然設置 5 個參數也可以正常使用,ThreadPoolExecutor 當任務過多(處理不過來)時提供了 4 種拒絕策略,當然我們也可以自定義拒絕策略,這樣回答我確定你這道題的面試肯定成功了,并且超長發揮了。
更多關于“java培訓”的問題,歡迎咨詢千鋒教育在線名師。千鋒教育多年辦學,課程大綱緊跟企業需求,更科學更嚴謹,每年培養泛IT人才近2萬人。不論你是零基礎還是想提升,都可以找到適合的班型,千鋒教育隨時歡迎你來試聽。