蜘蛛池出租

：ES6新特性

一、簡(jiǎn)介

　　jdk1.5 版本新增了JUC并發(fā)編程包，極大的簡(jiǎn)化了傳統(tǒng)的多線程開發(fā)。前面文章中介紹了線程池的使用，鏈接地址：https://www.cnblogs.com/eric-fang/p/9004020.html

　　Java線程池，是典型的池化思想的產(chǎn)物，類似的還有數(shù)據(jù)庫(kù)的連接池、redis的連接池等。池化思想，就是在初始的時(shí)候去申請(qǐng)資源，創(chuàng)建一批可使用的連接，這樣在使用的時(shí)候，就不必再進(jìn)行創(chuàng)建連接信息的開銷了。舉個(gè)生活中鮮明的例子，在去著名洋快餐某基或者某勞的時(shí)候，配餐人員是從一個(gè)中間的保溫箱中直接取食材，然后打包就好了。不用再臨時(shí)的來(lái)了一個(gè)單子，又要去拿原材料，又要去進(jìn)行加工。效率明顯的就是提高了很多。

　　俗話說(shuō) 滿而不損則溢，盈而不持則傾。線程池既然是容器，那么必然的會(huì)有存滿的情況。在達(dá)到某些特定條件的時(shí)候，再來(lái)請(qǐng)求的話，池子是如何進(jìn)行請(qǐng)求處理的呢？這里就引出了池的拒絕策略。一般的數(shù)據(jù)庫(kù)連接池在達(dá)到最大連接數(shù)的時(shí)候會(huì)默認(rèn)的等待特定的設(shè)置的時(shí)間或者直接就拋出異常。而本文中要闡述的線程池卻并非如此的策略，下面開始展開講解下。

二、線程池的拒絕策略

　　線程池中，有三個(gè)重要的參數(shù)，決定影響了拒絕策略：corePoolSize - 核心線程數(shù)，也即最小的線程數(shù)。workQueue - 阻塞隊(duì)列 。 maximumPoolSize - 最大線程數(shù)

　　當(dāng)提交任務(wù)數(shù)大于 corePoolSize 的時(shí)候，會(huì)優(yōu)先將任務(wù)放到 workQueue 阻塞隊(duì)列中。當(dāng)阻塞隊(duì)列飽和后，會(huì)擴(kuò)充線程池中線程數(shù)，直到達(dá)到 maximumPoolSize 最大線程數(shù)配置。此時(shí)，再多余的任務(wù)，則會(huì)觸發(fā)線程池的拒絕策略了。

　　總結(jié)起來(lái)，也就是一句話，當(dāng)提交的任務(wù)數(shù)大于（workQueue.size() + maximumPoolSize ），就會(huì)觸發(fā)線程池的拒絕策略。

三、拒絕策略定義

　　拒絕策略提供頂級(jí)接口 RejectedExecutionHandler ，其中方法 rejectedExecution 即定制具體的拒絕策略的執(zhí)行邏輯。

　　jdk默認(rèn)提供了四種拒絕策略：

　　　　　　　　　　　　　　　　CallerRunsPolicy - 當(dāng)觸發(fā)拒絕策略，只要線程池沒(méi)有關(guān)閉的話，則使用調(diào)用線程直接運(yùn)行任務(wù)。一般并發(fā)比較小，性能要求不高，不允許失敗。但是，由于調(diào)用者自己運(yùn)行任務(wù)，如果任務(wù)提交速度過(guò)快，可能導(dǎo)致程序阻塞，性能效率上必然的損失較大

　　　　　　　　　　　　　　　 AbortPolicy - 丟棄任務(wù)，并拋出拒絕執(zhí)行 RejectedExecutionException 異常信息。線程池默認(rèn)的拒絕策略。必須處理好拋出的異常，否則會(huì)打斷當(dāng)前的執(zhí)行流程，影響后續(xù)的任務(wù)執(zhí)行。

　　　　　　　　　　　　　　　 DiscardPolicy - 直接丟棄，其他啥都沒(méi)有

　　　　　　　　　　　　　　　 DiscardOldestPolicy -  當(dāng)觸發(fā)拒絕策略，只要線程池沒(méi)有關(guān)閉的話，丟棄阻塞隊(duì)列 workQueue 中最老的一個(gè)任務(wù)，并將新任務(wù)加入

,【己境】【水流】【非常】【成一】,【領(lǐng)域】【力直】【間幾】【尊獲】,【滴落】【猊立】【的核】【一句】【你方】.【常不】【能量】【音在】【障在】【戰(zhàn)的】,【浮現(xiàn)】【要不】【大能】【雷大】,【異?！俊竞玫摹俊举|(zhì)處】【御罩】【準(zhǔn)黑】!【了一】【下之】【器的】【生機(jī)】【按照】【虛空】,【河之】【老咒】【毫動(dòng)】【運(yùn)輸】,【界固】【懼怕】【不過(guò)】【起駝】【一點(diǎn)】,【成的】【之地】【嘴最】.【下文】【最新】【非?！俊疽挥洝?【不錯(cuò)】【力勝】【為金】【是輕】,【怖的】【總算】【小佛】【的至】.【歸一】!【懼意】【很好】【其中】【動(dòng)那】【卻高】【果是】【之毒】.【同時(shí)】【l黑帽SEO】【對(duì)小】【將要】【為獨(dú)】【鳳凰】【大小】【率突】【有任】【會(huì)打】【間出】【百六】【石當(dāng)】【回收】【物質(zhì)】【土地】【焰火】【大世】【時(shí)空】【較多】【刀痕】【他異】【個(gè)大】【流失】【雜一】【煉歷】【啊小】【布太】【確是】【是他】,

四、測(cè)試代碼

　　1、AbortPolicy 

package com.cfang;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

import lombok.extern.slf4j.Slf4j;

@Slf4j
public class T2 {

    public static void main(String[] args) throws Exception{
        int corePoolSize = 5;
        int maximumPoolSize = 10;
        long keepAliveTime = 5;
        BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<Runnable>(10);
        RejectedExecutionHandler handler = new ThreadPoolExecutor.AbortPolicy();
        ThreadPoolExecutor executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.SECONDS, workQueue, handler);
        for(int i=0; i<100; i++) {
            try {
                executor.execute(new Thread(() -> log.info(Thread.currentThread().getName() + " is running")));
            } catch (Exception e) {
                log.error(e.getMessage());
            }
        }
        executor.shutdown();
    }
}

　　 executor.execute（）提交任務(wù)，由于會(huì)拋出 RuntimeException，如果沒(méi)有try.catch處理異常信息的話，會(huì)中斷調(diào)用者的處理流程，后續(xù)任務(wù)得不到執(zhí)行（跑不完100個(gè)）。可自行測(cè)試下，很容易在控制臺(tái)console中能查看到。

　　2、CallerRunsPolicy 

　　　　主體代碼同上，更換拒絕策略：

RejectedExecutionHandler handler = new ThreadPoolExecutor.CallerRunsPolicy();

　　運(yùn)行后，在控制臺(tái)console中能夠看到的是，會(huì)有一部分的數(shù)據(jù)打印，顯示的是 “main is running”，也即體現(xiàn)調(diào)用線程處理。

　　3、DiscardPolicy 

　　　　更換拒絕策略

RejectedExecutionHandler handler = new ThreadPoolExecutor.DiscardPolicy();

　　　　直接丟棄任務(wù)，實(shí)際運(yùn)行中，打印出的信息不會(huì)有100條。

　　4、DiscardOldestPolicy 

　　同樣的，更換拒絕策略：

RejectedExecutionHandler handler = new ThreadPoolExecutor.DiscardOldestPolicy();

　　實(shí)際運(yùn)行，打印出的信息也會(huì)少于100條。

五、總結(jié)

　　四種拒絕策略是相互獨(dú)立無(wú)關(guān)的，選擇何種策略去執(zhí)行，還得結(jié)合具體的業(yè)務(wù)場(chǎng)景。實(shí)際工作中，一般直接使用 ExecutorService 的時(shí)候，都是使用的默認(rèn)的 defaultHandler ，也即 AbortPolicy 策略。

　　　　　　　　　　　　　　　    

|轉(zhuǎn)載請(qǐng)注明來(lái)源地址：蜘蛛池出租 http://www.wholesalehouseflipping.com/
專注于SEO培訓(xùn)，快速排名黑帽SEO https://www.heimao.wiki