最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

Java多線程中的ThreadPoolExecutor解讀

 更新時(shí)間:2023年09月15日 10:07:34   作者:「已注銷」  
這篇文章主要介紹了Java多線程中的ThreadPoolExecutor解讀,線程池中的核心線程數(shù),當(dāng)提交一個任務(wù)時(shí),線程池創(chuàng)建一個新線程執(zhí)行任務(wù),直到當(dāng)前線程數(shù)等于corePoolSize;如果當(dāng)前線程數(shù)為corePoolSize,繼續(xù)提交的任務(wù)被保存到阻塞隊(duì)列中,等待被執(zhí)行,需要的朋友可以參考下

corePoolSize

線程池中的核心線程數(shù)。當(dāng)提交一個任務(wù)時(shí),線程池創(chuàng)建一個新線程執(zhí)行任務(wù),直到當(dāng)前線程數(shù)等于corePoolSize;如果當(dāng)前線程數(shù)為corePoolSize,繼續(xù)提交的任務(wù)被保存到阻塞隊(duì)列中,等待被執(zhí)行。

maximumPoolSize

線程池中允許的最大線程數(shù)。如果當(dāng)前阻塞隊(duì)列滿了,且繼續(xù)提交任務(wù),則創(chuàng)建新的線程執(zhí)行任務(wù),前提是當(dāng)前線程數(shù)小于maximumPoolSize。

keepAliveTime

線程空閑時(shí)的存活時(shí)間。默認(rèn)情況下,只有當(dāng)線程池中的線程數(shù)大于corePoolSize時(shí),keepAliveTime才會起作用,如果一個線程空閑的時(shí)間達(dá)到keepAliveTime,則會終止,直到線程池中的線程數(shù)不超過corePoolSize。但是如果調(diào)用了allowCoreThreadTimeOut(boolean)方法,keepAliveTime參數(shù)也會起作用,直到線程池中的線程數(shù)為0。

unit

keepAliveTime參數(shù)的時(shí)間單位。

workQueue

任務(wù)緩存隊(duì)列,用來存放等待執(zhí)行的任務(wù)。如果當(dāng)前線程數(shù)為corePoolSize,繼續(xù)提交的任務(wù)就會被保存到任務(wù)緩存隊(duì)列中,等待被執(zhí)行。 一般來說,這里的BlockingQueue有以下三種選擇:

1.SynchronousQueue:一個不存儲元素的阻塞隊(duì)列,每個插入操作必須等到另一個線程調(diào)用移除操作,否則插入操作一直處于阻塞狀態(tài)。因此,如果線程池中始終沒有空閑線程(任務(wù)提交的平均速度快于被處理的速度),可能出現(xiàn)無限制的線程增長。

2.LinkedBlockingQueue:基于鏈表結(jié)構(gòu)的阻塞隊(duì)列,如果不設(shè)置初始化容量,其容量為Integer.MAX_VALUE,即為無界隊(duì)列。因此,如果線程池中線程數(shù)達(dá)到了corePoolSize,且始終沒有空閑線程(任務(wù)提交的平均速度快于被處理的速度),任務(wù)緩存隊(duì)列可能出現(xiàn)無限制的增長。

3.ArrayBlockingQueue:基于數(shù)組結(jié)構(gòu)的有界阻塞隊(duì)列,按FIFO排序任務(wù)。

threadFactory

線程工廠,創(chuàng)建新線程時(shí)使用的線程工廠。

handler

任務(wù)拒絕策略,當(dāng)阻塞隊(duì)列滿了,且線程池中的線程數(shù)達(dá)到maximumPoolSize,如果繼續(xù)提交任務(wù),就會采取任務(wù)拒絕策略處理該任務(wù),線程池提供了4種任務(wù)拒絕策略:

1.AbortPolicy:丟棄任務(wù)并拋出RejectedExecutionException異常,默認(rèn)策略;

2.CallerRunsPolicy:由調(diào)用execute方法的線程執(zhí)行該任務(wù);

3.DiscardPolicy:丟棄任務(wù),但是不拋出異常;

4.DiscardOldestPolicy:丟棄阻塞隊(duì)列最前面的任務(wù),然后重新嘗試執(zhí)行任務(wù)(重復(fù)此過程)。 當(dāng)然也可以根據(jù)應(yīng)用場景實(shí)現(xiàn)RejectedExecutionHandler接口,自定義飽和策略,如記錄日志或持久化存儲不能處理的任務(wù)。

public static void main(String[] args) {
    int corePoolSize = 0;
    int maximumPoolSize = 0;
    long keepAliveTime = 0;
    TimeUnit unit = TimeUnit.SECONDS;
    //1.SynchronousQueue:一個不存儲元素的阻塞隊(duì)列,每個插入操作必須等到另一個線程調(diào)用移除操作,
    //否則插入操作一直處于阻塞狀態(tài)。因此,如果線程池中始終沒有空閑線程(任務(wù)提交的平均速度快于被處理的速度),
    //可能出現(xiàn)無限制的線程增長。
    //2.LinkedBlockingQueue:基于鏈表結(jié)構(gòu)的阻塞隊(duì)列,如果不設(shè)置初始化容量,
    //其容量為Integer.MAX_VALUE,即為無界隊(duì)列。因此,如果線程池中線程數(shù)達(dá)到了corePoolSize,
    //且始終沒有空閑線程(任務(wù)提交的平均速度快于被處理的速度),任務(wù)緩存隊(duì)列可能出現(xiàn)無限制的增長。
    //3.ArrayBlockingQueue:基于數(shù)組結(jié)構(gòu)的有界阻塞隊(duì)列,按FIFO排序任務(wù)。
    BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(100);
    ThreadFactory threadFactory = new ThreadFactory() {
      @Override
      public Thread newThread(Runnable r) {
        return new Thread("newThread");
      }
    };
    //1.AbortPolicy:丟棄任務(wù)并拋出RejectedExecutionException異常,默認(rèn)策略;
    //2.CallerRunsPolicy:由調(diào)用execute方法的線程執(zhí)行該任務(wù);
    //3.DiscardPolicy:丟棄任務(wù),但是不拋出異常;
    //4.DiscardOldestPolicy:丟棄阻塞隊(duì)列最前面的任務(wù),然后重新嘗試執(zhí)行任務(wù)(重復(fù)此過程)。
    RejectedExecutionHandler handler = new RejectedExecutionHandler() {
      @Override
      public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
      }
    };
    ThreadPoolExecutor threadPoolExecutor = 
        new ThreadPoolExecutor(
            corePoolSize, 
            maximumPoolSize, 
            keepAliveTime,
            unit, 
            workQueue);
    ThreadPoolExecutor threadPoolExecutor1 = 
        new ThreadPoolExecutor(
            corePoolSize, 
            maximumPoolSize, 
            keepAliveTime,
            unit, 
            workQueue, 
            threadFactory);
    ThreadPoolExecutor threadPoolExecutor2 = 
        new ThreadPoolExecutor(
            corePoolSize, 
            maximumPoolSize, 
            keepAliveTime, 
            unit, 
            workQueue, 
            handler);
    ThreadPoolExecutor threadPoolExecutor3 = 
        new ThreadPoolExecutor(
            corePoolSize, 
            maximumPoolSize, 
            keepAliveTime, 
            unit, 
            workQueue, 
            threadFactory, 
            handler);
  }

到此這篇關(guān)于Java多線程中的ThreadPoolExecutor解讀的文章就介紹到這了,更多相關(guān)ThreadPoolExecutor解讀內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • Spring Boot優(yōu)化后啟動速度快到飛起技巧示例

    Spring Boot優(yōu)化后啟動速度快到飛起技巧示例

    這篇文章主要為大家介紹了Spring Boot優(yōu)化后啟動速度快到飛起的技巧示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2022-07-07
  • java實(shí)現(xiàn)微信搶紅包算法

    java實(shí)現(xiàn)微信搶紅包算法

    這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)微信搶紅包算法,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2020-09-09
  • 新版idea如何開啟多臺JVM虛擬機(jī)的流程步驟

    新版idea如何開啟多臺JVM虛擬機(jī)的流程步驟

    在IntelliJ?IDEA這個集成開發(fā)環(huán)境中(IDE),開啟JVM(Java?Virtual?Machine)通常是在運(yùn)行Java應(yīng)用程序時(shí)的操作,本文給大家介紹了新版idea如何開啟多臺JVM虛擬機(jī)的流程步驟,需要的朋友可以參考下
    2024-10-10
  • Java簡單實(shí)現(xiàn)SpringMVC+MyBatis分頁插件

    Java簡單實(shí)現(xiàn)SpringMVC+MyBatis分頁插件

    自己最近搭建的一個SpringMVC+Mybatis的框架 屬于無實(shí)體類的框架 并實(shí)現(xiàn)了Myabtis的自動分頁和總數(shù)查詢 只要傳入分頁參數(shù)便能自動查詢總數(shù)和分頁 總數(shù)封裝在參數(shù)里面執(zhí)行查詢后可以直接從參數(shù)中獲取
    2015-09-09
  • java實(shí)現(xiàn)一個簡單的Web服務(wù)器實(shí)例解析

    java實(shí)現(xiàn)一個簡單的Web服務(wù)器實(shí)例解析

    這篇文章主要介紹了java實(shí)現(xiàn)一個簡單的Web服務(wù)器實(shí)例解析,分享了相關(guān)代碼示例,小編覺得還是挺不錯的,具有一定借鑒價(jià)值,需要的朋友可以參考下
    2018-02-02
  • IDEA-Maven項(xiàng)目的jdk版本設(shè)置方法

    IDEA-Maven項(xiàng)目的jdk版本設(shè)置方法

    我們需要設(shè)置jdk的版本,不然會提示導(dǎo)致語法錯誤,這篇文章主要介紹了IDEA-Maven項(xiàng)目的jdk版本設(shè)置方法,小編覺得不錯,一起來了解一下
    2019-04-04
  • Java中SynchronousQueue的底層實(shí)現(xiàn)原理剖析

    Java中SynchronousQueue的底層實(shí)現(xiàn)原理剖析

    BlockingQueue的實(shí)現(xiàn)類中,有一種阻塞隊(duì)列比較特殊,就是SynchronousQueue(同步移交隊(duì)列),隊(duì)列長度為0。本文就來剖析一下SynchronousQueue的底層實(shí)現(xiàn)原理,感興趣的可以了解一下
    2022-11-11
  • 基于創(chuàng)建Web項(xiàng)目運(yùn)行時(shí)出錯的解決方法(必看篇)

    基于創(chuàng)建Web項(xiàng)目運(yùn)行時(shí)出錯的解決方法(必看篇)

    下面小編就為大家?guī)硪黄趧?chuàng)建Web項(xiàng)目運(yùn)行時(shí)出錯的解決方法。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-08-08
  • java依賴混亂存在的問題與解決方案

    java依賴混亂存在的問題與解決方案

    這篇文章主要為大家介紹了java依賴混亂存在的問題與解決方案,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-09-09
  • Java?8?的異步編程利器?CompletableFuture的實(shí)例詳解

    Java?8?的異步編程利器?CompletableFuture的實(shí)例詳解

    這篇文章主要介紹了Java?8?的異步編程利器?CompletableFuture?詳解,本文通過一個例子給大家介紹下Java?8??CompletableFuture異步編程的相關(guān)知識,需要的朋友可以參考下
    2022-03-03

最新評論

左贡县| 涞源县| 汕尾市| 布尔津县| 余庆县| 安塞县| 湘西| 望奎县| 南宫市| 隆安县| 张家港市| 富锦市| 济南市| 惠安县| 黔西县| 雷州市| 七台河市| 左贡县| 宁国市| 邯郸市| 且末县| 衡山县| 兰溪市| 望奎县| 汤阴县| 奉节县| 巫溪县| 错那县| 永吉县| 栖霞市| 十堰市| 团风县| 包头市| 乐平市| 洪江市| 突泉县| 天津市| 康马县| 通辽市| 昌都县| 临泽县|