亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

Java多線程中的ThreadPoolExecutor解讀

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

corePoolSize

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

maximumPoolSize

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

keepAliveTime

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

unit

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

workQueue

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

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

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

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

threadFactory

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

handler

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

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

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

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

4.DiscardOldestPolicy:丟棄阻塞隊列最前面的任務(wù),然后重新嘗試執(zhí)行任務(wù)(重復(fù)此過程)。 當然也可以根據(jù)應(yīng)用場景實現(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:一個不存儲元素的阻塞隊列,每個插入操作必須等到另一個線程調(diào)用移除操作,
    //否則插入操作一直處于阻塞狀態(tài)。因此,如果線程池中始終沒有空閑線程(任務(wù)提交的平均速度快于被處理的速度),
    //可能出現(xiàn)無限制的線程增長。
    //2.LinkedBlockingQueue:基于鏈表結(jié)構(gòu)的阻塞隊列,如果不設(shè)置初始化容量,
    //其容量為Integer.MAX_VALUE,即為無界隊列。因此,如果線程池中線程數(shù)達到了corePoolSize,
    //且始終沒有空閑線程(任務(wù)提交的平均速度快于被處理的速度),任務(wù)緩存隊列可能出現(xiàn)無限制的增長。
    //3.ArrayBlockingQueue:基于數(shù)組結(jié)構(gòu)的有界阻塞隊列,按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異常,默認策略;
    //2.CallerRunsPolicy:由調(diào)用execute方法的線程執(zhí)行該任務(wù);
    //3.DiscardPolicy:丟棄任務(wù),但是不拋出異常;
    //4.DiscardOldestPolicy:丟棄阻塞隊列最前面的任務(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)文章

  • springboot配置ldaps連接方式

    springboot配置ldaps連接方式

    這篇文章主要介紹了springboot配置ldaps連接方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2024-05-05
  • SpringBoot-Maven打包壓縮瘦身方式

    SpringBoot-Maven打包壓縮瘦身方式

    這篇文章主要介紹了SpringBoot-Maven打包壓縮瘦身方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2024-05-05
  • SpringBoot整合Guava Cache實現(xiàn)全局緩存的示例代碼

    SpringBoot整合Guava Cache實現(xiàn)全局緩存的示例代碼

    這篇文章主要介紹了SpringBoot整合Guava Cache實現(xiàn)全局緩存,Guava Cache是Google Guava庫中的一個模塊,提供了基于內(nèi)存的本地緩存實現(xiàn),文中介紹了SpringBoot整合使用Guava Cache的具體步驟,需要的朋友可以參考下
    2024-03-03
  • Python單元測試_使用裝飾器實現(xiàn)測試跳過和預(yù)期故障的方法

    Python單元測試_使用裝飾器實現(xiàn)測試跳過和預(yù)期故障的方法

    下面小編就為大家?guī)硪黄狿ython單元測試_使用裝飾器實現(xiàn)測試跳過和預(yù)期故障的方法。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-06-06
  • SpringBoot 嵌入式web容器的啟動原理詳解

    SpringBoot 嵌入式web容器的啟動原理詳解

    這篇文章主要介紹了SpringBoot 嵌入式web容器的啟動原理詳解,具有很好的參考價值,希望對大家有所幫助。
    2021-11-11
  • Java8對List排序的方法大全

    Java8對List排序的方法大全

    這篇文章主要給大家介紹了關(guān)于Java8對List排序的方法大全,其實Java針對數(shù)組和List的排序都有實現(xiàn),文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下
    2023-07-07
  • Maven中plugins與pluginManagement的區(qū)別說明

    Maven中plugins與pluginManagement的區(qū)別說明

    這篇文章主要介紹了Maven中plugins與pluginManagement的區(qū)別說明,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-09-09
  • 詳解JAVA中static的作用

    詳解JAVA中static的作用

    這篇文章主要介紹了JAVA中static的作用,文中講解非常細致,代碼幫助大家更好的理解,感興趣的朋友可以了解下
    2020-06-06
  • springMVC如何將controller中數(shù)據(jù)傳遞到j(luò)sp頁面

    springMVC如何將controller中數(shù)據(jù)傳遞到j(luò)sp頁面

    這篇文章主要介紹了springMVC如何將controller中數(shù)據(jù)傳遞到j(luò)sp頁面,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2017-07-07
  • Java ByteBuffer網(wǎng)絡(luò)編程用法實例解析

    Java ByteBuffer網(wǎng)絡(luò)編程用法實例解析

    這篇文章主要介紹了Java ByteBuffer網(wǎng)絡(luò)編程用法實例解析,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2020-10-10

最新評論