Java多線程實(shí)現(xiàn)之Executor詳解
Executor 通過創(chuàng)建線程池的方式來管理線程,需要的朋友可以參考下
Executor 線程實(shí)現(xiàn)
Runnable runnable = new Runnable() { @Override public void run() { System.out.println("runnable 線程開始執(zhí)行"); } }; Executor executor = Executors.newCachedThreadPool(); executor.execute(runnable); executor.execute(runnable); executor.execute(runnable);
1 Executor 簡(jiǎn)介
- Executor 給他一個(gè) Runnable,他就能自動(dòng)很安全的幫你把這個(gè)線程執(zhí)行完畢
- Executor 通過創(chuàng)建線程池的方式來管理線程
- Executor 有五種創(chuàng)建線程池的方式,其中 newCachedThreadPool() 是一種非常簡(jiǎn)單的線程池創(chuàng)建方式
- Executor 有兩種結(jié)束方式,shutDown() 和 shutDownNow()
- shutDown 會(huì)將當(dāng)前正在執(zhí)行的和排隊(duì)中的線程執(zhí)行完畢后結(jié)束,并且不允許有新的線程加入到待執(zhí)行隊(duì)列中
- shutDownNow 會(huì)立即結(jié)束執(zhí)行,采取的是一種比較安全的結(jié)束方式:interrupt()
2 Executor 中 其他幾種創(chuàng)建線程池的方式
2.1 Executor 中的第一種線程池創(chuàng)建方式 newCachedThreadPool()
public static ExecutorService newCachedThreadPool() { return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()); }
newCachedThreadPool() 的實(shí)現(xiàn):
在 newCachedThreadPool 中,會(huì)直接返回一個(gè) ThreadPoolExecutor,這里解釋一下創(chuàng)建 ThreadPoolExecutor 的幾個(gè)參數(shù):
/** * @param corePoolSize 代表默認(rèn)線程數(shù),或者說最低線程數(shù),也就是此線程池創(chuàng)建后里面立馬會(huì)有幾個(gè)線程的數(shù)量 * @param maximumPoolSize 代表最大線程數(shù),超過此線程數(shù)量則排隊(duì)等待執(zhí)行,排隊(duì)線程放入最后一個(gè)參數(shù)中 * @param keepAliveTime 表示默認(rèn)線程數(shù)量外的已經(jīng)創(chuàng)建出來的線程在處于空閑狀態(tài)下,被回收前需要等待的時(shí)間 * @param unit 表示第三個(gè)時(shí)間值的單位 * @param workQueue 用于盛放多余任務(wù)的線程隊(duì)列 */ ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)
- 第一個(gè)參數(shù)代表默認(rèn)線程數(shù),或者說最低線程數(shù),也就是此線程池創(chuàng)建后里面立馬會(huì)有幾個(gè)線程的數(shù)量
- 第二個(gè)參數(shù)代表最大線程數(shù),超過此線程數(shù)量則排隊(duì)等待執(zhí)行,排隊(duì)線程放入最后一個(gè)參數(shù)中
- 第三個(gè)參數(shù)表示默認(rèn)線程數(shù)量外的已經(jīng)創(chuàng)建出來的線程在處于空閑狀態(tài)下,被回收前需要等待的時(shí)間
- 第四個(gè)參數(shù)表示第三個(gè)時(shí)間值的單位
- 第五個(gè)參數(shù)用于盛放多余任務(wù)的線程隊(duì)列
例:
假如說傳入的值分別為 5,20,10L,TimeUnit.SECONDS,new SynchronousQueue< Runnable>()
則表示,創(chuàng)建一個(gè)默認(rèn)數(shù)量為 5 的線程池,這個(gè)線程池最多允許 20 條線程同時(shí)工作,如果超過 20 個(gè)則存放進(jìn)隊(duì)列中等待這 20 個(gè)線程騰出位置,每個(gè)線程執(zhí)行完畢都去隊(duì)列中取新的任務(wù)并執(zhí)行,如果隊(duì)列中沒有新的任務(wù),則線程等待 10 秒,如果 10 后仍然沒有新的任務(wù),則線程會(huì)被回收,一直回收到只剩余 5 個(gè)線程
2.1 Executor.newSingleThreadExecutor()
public static ExecutorService newSingleThreadExecutor() { return new FinalizableDelegatedExecutorService (new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>())); }
通過前兩個(gè)參數(shù)可以看出,這是創(chuàng)建單線程的線程池,也就是說這個(gè)線程池中只有一個(gè)線程,并且最多也只能有一個(gè)線程,應(yīng)用場(chǎng)景比較少。
2.2 Executor.newFixedThreadPool()
public static ExecutorService newFixedThreadPool(int nThreads) { return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()); }
創(chuàng)建固定數(shù)量線程的線程池,通過前兩個(gè)參數(shù)可以看出,傳入的參數(shù)被同時(shí)應(yīng)用中前兩個(gè)參數(shù)中,這就意味著我創(chuàng)建一個(gè)線程池,里面的默認(rèn)線程數(shù)和最大線程數(shù)一致
并且不能擴(kuò)容、不被回收,一直放在那里,表面上可能比較合理,但實(shí)際的應(yīng)用場(chǎng)景也很少
在處理瞬時(shí)爆發(fā)性任務(wù)時(shí)會(huì)能用得到,例:
Runnable precessImageRunner = new Runnable() { @Override public void run() { System.out.println("開始處理圖片了,我很耗時(shí),,,,"); } }; List<Bitmap> bitmaps = new ArrayList<>(); ExecutorService fixedExecutor = Executors.newFixedThreadPool(30); for (Bitmap bitmap : bitmaps) { fixedExecutor.execute(precessImageRunner); } fixedExecutor.shutdown();
fixedExecutor.shutdown() 來防止永遠(yuǎn)不回收造成資源浪費(fèi)的情況
Executor.newScheduledThreadPool()
創(chuàng)建一個(gè)延遲的線程池
Executor.newSingleThreadScheduledExecutor()
創(chuàng)建一個(gè)延遲的單線程線程池
總結(jié)
以上就是 Executor 的簡(jiǎn)介及 Executor 五種創(chuàng)建線程的方式,你學(xué)廢了嗎?
復(fù)習(xí)一遍:
// Executor 五種創(chuàng)建線程的方式 Executors.newCachedThreadPool(); Executors.newSingleThreadExecutor(); Executors.newFixedThreadPool(); Executors.newScheduledThreadPool(); Executors.newSingleThreadScheduledExecutor();
到此這篇關(guān)于Java多線程實(shí)現(xiàn)之Executor詳解的文章就介紹到這了,更多相關(guān)Java多線程Executor內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
為什么mybatis中的SqlSession一定要關(guān)閉
這篇文章主要介紹了為什么mybatis中的SqlSession一定要關(guān)閉,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-12-12Geotools實(shí)現(xiàn)shape文件的寫入功能
Geotools作為開源的Java?GIS三方庫(kù),已經(jīng)成為GIS服務(wù)器端的主流開源庫(kù),其功能非常強(qiáng)大,涉及到GIS業(yè)務(wù)的方方面面,其中就包括GIS數(shù)據(jù)的讀寫,今天小編就借助Geotools來實(shí)現(xiàn)shape數(shù)據(jù)的寫入,需要的朋友可以參考下2023-08-08Java?LinkedList實(shí)現(xiàn)班級(jí)信息管理系統(tǒng)
這篇文章主要為大家詳細(xì)介紹了Java?LinkedList實(shí)現(xiàn)班級(jí)信息管理系統(tǒng),文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2022-02-02谷歌二維碼引擎com.google.zxing二維碼生成與解析
這篇文章主要給大家介紹了關(guān)于谷歌二維碼引擎com.google.zxing二維碼生成與解析的相關(guān)資料,zxing是google開源的二維碼生成和解析工具,需要的朋友可以參考下2023-07-07詳解SpringMVC的類型轉(zhuǎn)換及驗(yàn)證方法
在本篇文章里面我們給大家詳細(xì)分析了SpringMVC的類型轉(zhuǎn)換及驗(yàn)證方法的相關(guān)知識(shí),對(duì)此有需要的朋友們學(xué)習(xí)下吧。2018-10-10Java實(shí)現(xiàn)學(xué)生管理系統(tǒng)詳解
這篇文章主要為大家詳細(xì)介紹了Java實(shí)現(xiàn)學(xué)生管理系統(tǒng),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下,希望能夠給你帶來幫助2021-10-10java實(shí)現(xiàn)通訊錄管理系統(tǒng)
這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)通訊錄管理系統(tǒng),文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2020-07-07簡(jiǎn)單了解Mybatis如何實(shí)現(xiàn)SQL防注入
這篇文章主要介紹了簡(jiǎn)單了解Mybatis如何實(shí)現(xiàn)SQL防注入,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-01-01