Java 線程池框架
一、線程池結(jié)構(gòu)圖
二、示例
定義線程接口
public class MyThread extends Thread { @Override publicvoid run() { System.out.println(Thread.currentThread().getName() + "正在執(zhí)行"); } }
1:newSingleThreadExecutor
ExecutorService pool = Executors. newSingleThreadExecutor(); Thread t1 = new MyThread(); Thread t2 = new MyThread(); Thread t3 = new MyThread(); //將線程放入池中進(jìn)行執(zhí)行 pool.execute(t1); pool.execute(t2); pool.execute(t3); //關(guān)閉線程池 pool.shutdown();
輸入結(jié)果:
pool-1-thread-1正在執(zhí)行 pool-1-thread-1正在執(zhí)行 pool-1-thread-1正在執(zhí)行
2:newFixedThreadPool
ExecutorService pool = Executors.newFixedThreadPool(3); Thread t1 = new MyThread(); Thread t2 = new MyThread(); Thread t3 = new MyThread(); Thread t4 = new MyThread(); Thread t5 = new MyThread(); //將線程放入池中進(jìn)行執(zhí)行 pool.execute(t1); pool.execute(t2); pool.execute(t3); pool.execute(t4); pool.execute(t5); pool.shutdown();
輸入結(jié)果:
pool-1-thread-1正在執(zhí)行 pool-1-thread-2正在執(zhí)行 pool-1-thread-1正在執(zhí)行 pool-1-thread-2正在執(zhí)行
3 :newCachedThreadPool
ExecutorService pool = Executors.newCachedThreadPool(); Thread t1 = new MyThread(); Thread t2 = new MyThread(); Thread t3 = new MyThread(); Thread t4 = new MyThread(); Thread t5 = new MyThread(); //將線程放入池中進(jìn)行執(zhí)行 pool.execute(t1); pool.execute(t2); pool.execute(t3); pool.execute(t4); pool.execute(t5); //關(guān)閉線程池 pool.shutdown();
輸入結(jié)果:
pool-1-thread-2正在執(zhí)行 pool-1-thread-4正在執(zhí)行 pool-1-thread-3正在執(zhí)行 pool-1-thread-1正在執(zhí)行 pool-1-thread-5正在執(zhí)行
4 :ScheduledThreadPoolExecutor
ScheduledExecutorService pool = Executors.newScheduledThreadPool(2); pool.scheduleAtFixedRate(new Runnable() {//每隔一段時(shí)間就觸發(fā)異常 @Override public void run() { //throw new RuntimeException(); System.out.println("================"); } }, 1000, 2000, TimeUnit.MILLISECONDS); pool.scheduleAtFixedRate(new Runnable() {//每隔一段時(shí)間打印系統(tǒng)時(shí)間,證明兩者是互不影響的 @Override public void run() { System.out.println("+++++++++++++++++"); } }, 1000, 2000, TimeUnit.MILLISECONDS);
輸入結(jié)果:
================ +++++++++++++++++ +++++++++++++++++ +++++++++++++++++
三、線程池核心參數(shù)
corePoolSize : 池中核心的線程數(shù)
maximumPoolSize : 池中允許的最大線程數(shù)。
keepAliveTime : 當(dāng)線程數(shù)大于核心時(shí),此為終止前多余的空閑線程等待新任務(wù)的最長(zhǎng)時(shí)間。
unit : keepAliveTime 參數(shù)的時(shí)間單位。
workQueue : 執(zhí)行前用于保持任務(wù)的隊(duì)列。此隊(duì)列僅保持由 execute方法提交的 Runnable任務(wù)。
threadFactory : 執(zhí)行程序創(chuàng)建新線程時(shí)使用的工廠。
handler : 由于超出線程范圍和隊(duì)列容量而使執(zhí)行被阻塞時(shí)所使用的處理程序。
ThreadPoolExecutor :Executors類(lèi)的底層實(shí)現(xiàn)。
3.1 任務(wù)排隊(duì)機(jī)制
SynchonousQueue: 同步隊(duì)列,隊(duì)列直接提交給線程執(zhí)行而不保持它們,此時(shí)線程池通常是無(wú)界的
LinkedBlockingQueue: 無(wú)界對(duì)列,當(dāng)線程池線程數(shù)達(dá)到最大數(shù)量時(shí),新任務(wù)就會(huì)在隊(duì)列中等待執(zhí)行,可能會(huì)造成隊(duì)列無(wú)限膨脹
ArrayBlockingQueue : 有界隊(duì)列,有助于防止資源耗盡,一旦達(dá)到上限,可能會(huì)造成新任務(wù)丟失
注意:
newSingleThreadExecutor、newFixedThreadPool使用的是LinkedBlockingQueue
newCachedThreadPool 使用的是 SynchonousQueue
newScheduledThreadPool使用的是 DelayedWorkQueue
3.2 線程執(zhí)行流程
3.3 線程大小確定:
cpu密集型: 盡量少開(kāi)線程,最佳線程數(shù) Ncpu+1
io密集型:多開(kāi)線程,2Ncpu
混合型:根據(jù)情況而定,可以拆分成io密集和cou密集
以上就是本文的全部?jī)?nèi)容,希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作能帶來(lái)一定的幫助,同時(shí)也希望多多支持腳本之家!
相關(guān)文章
Java使用JDBC連接數(shù)據(jù)庫(kù)的詳細(xì)步驟
本文詳細(xì)講解了Java使用JDBC連接數(shù)據(jù)庫(kù)的詳細(xì)步驟,對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-01-01基于Java方式實(shí)現(xiàn)數(shù)據(jù)同步
這篇文章主要為大家詳細(xì)介紹了基于Java方式實(shí)現(xiàn)數(shù)據(jù)同步,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2022-08-08利用Java讀取Word表格中文本和圖片的方法實(shí)例
這篇文章主要給大家介紹了關(guān)于如何利用Java讀取Word表格中文本和圖片的相關(guān)資料,主要利用的是free spire.doc.jar 包,文中通過(guò)圖文介紹的非常詳細(xì),需要的朋友可以參考下2021-07-07SpringBoot啟動(dòng)java.nio.charset.MalformedInputException: I
本文主要介紹了SpringBoot啟動(dòng)java.nio.charset.MalformedInputException: Input length = 1報(bào)錯(cuò)的解決方案2023-07-07springboot項(xiàng)目打docker鏡像實(shí)例(入門(mén)級(jí))
最近做個(gè)項(xiàng)目,我們想把自己的程序打包成鏡像,并運(yùn)行在docker容器中,本文主要介紹了springboot項(xiàng)目打docker鏡像實(shí)例,具有一定的參考價(jià)值,感興趣的可以了解一下2024-06-06java使用XSSFWorkbook實(shí)現(xiàn)讀寫(xiě)Excel
這篇文章主要為大家詳細(xì)介紹了java如何通過(guò)使用XSSFWorkbook實(shí)現(xiàn)讀寫(xiě)Excel功能,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-04-04