引導(dǎo)

要求：線程資源必須通過線程池提供，不允許在應(yīng)用自行顯式創(chuàng)建線程；

說明：使用線程池的好處是減少在創(chuàng)建和銷毀線程上所花的時間以及系統(tǒng)資源的開銷，解決資源不足的問題。如果不使用線程池，有可能造成系統(tǒng)創(chuàng)建大量同類線程而導(dǎo)致消耗內(nèi)存或者“過度切換”的問題。

線程池介紹線程池概述

  線程池，顧名思義是一個放著線程的池子，這個池子的線程主要是用來執(zhí)行任務(wù)的。當用戶提交任務(wù)時，線程池會創(chuàng)建線程去執(zhí)行任務(wù)，若任務(wù)超過了核心線程數(shù)的時候，會在一個任務(wù)隊列里進行排隊等待，這個詳細流程，我們會后面細講。   任務(wù)，通常是一些抽象的且離散的工作單元，我們會把應(yīng)用程序的工作分解到多個任務(wù)中去執(zhí)行。一般我們需要使用多線程執(zhí)行任務(wù)的時候，這些任務(wù)最好都是相互獨立的，這樣有一定的任務(wù)邊界供程序把控。   多線程，當使用多線程的時候，任務(wù)處理過程就可以從主線程中剝離出來，任務(wù)可以并行處理，同時處理多個請求。當然了，任務(wù)處理代碼必須是線程安全的。

為何要使用線程池？

降低開銷：在創(chuàng)建和銷毀線程的時候會產(chǎn)生很大的系統(tǒng)開銷，頻繁創(chuàng)建/銷毀意味著CPU資源的頻繁切換和占用，線程是屬于稀缺資源，不可以頻繁的創(chuàng)建。假設(shè)創(chuàng)建線程的時長記為t1，線程執(zhí)行任務(wù)的時長記為t2，銷毀線程的時長記為t3，如果我們執(zhí)行任務(wù)t2<t1+t3，那么這樣的開銷是不劃算的，不使用線程池去避免創(chuàng)建和銷毀的開銷，將是極大的資源浪費。

易復(fù)用和管理：將線程都放在一個池子里，便于統(tǒng)一管理（可以延時執(zhí)行，可以統(tǒng)一命名線程名稱等），同時，也便于任務(wù)進行復(fù)用。

解耦：將線程的創(chuàng)建和銷毀與執(zhí)行任務(wù)完全分離出來，這樣方便于我們進行維護，也讓我們更專注于業(yè)務(wù)開發(fā)。線程池的優(yōu)勢提高資源的利用性：通過池化可以重復(fù)利用已創(chuàng)建的線程，空閑線程可以處理新提交的任務(wù)，從而降低了創(chuàng)建和銷毀線程的資源開銷。提高線程的管理性：在一個線程池中管理執(zhí)行任務(wù)的線程，對線程可以進行統(tǒng)一的創(chuàng)建、銷毀以及監(jiān)控等，對線程數(shù)做控制，防止線程的無限制創(chuàng)建，避免線程數(shù)量的急劇上升而導(dǎo)致CPU過度調(diào)度等問題，從而更合理的分配和使用內(nèi)核資源。提高程序的響應(yīng)性：提交任務(wù)后，有空閑線程可以直接去執(zhí)行任務(wù)，無需新建。提高系統(tǒng)的可擴展性：利用線程池可以更好的擴展一些功能，比如定時線程池可以實現(xiàn)系統(tǒng)的定時任務(wù)。線程池原理線程池的參數(shù)類型

一共有7個：corePoolSize、maximumPoolSize、keepAliveTime、unit、workQueue、threadFactory、handler，（5+2，前5個重要）

int corePoolSize：該線程池中核心線程數(shù)最大值

這邊我們區(qū)分兩個概念：

核心線程：線程池新建線程的時候，當前線程總數(shù)< corePoolSize，新建的線程即為核心線程。非核心線程：線程池新建線程的時候，當前線程總數(shù)< corePoolSize，新建的線程即為核心線程。

核心線程默認情況下會一直存活在線程池中，即使這個核心線程不工作(空閑狀態(tài))，除非ThreadPoolExecutor 的 allowCoreThreadTimeOut這個屬性為 true，那么核心線程如果空閑狀態(tài)下，超過一定時間后就被銷毀。

int maximumPoolSize：線程總數(shù)最大值

線程總數(shù) = 核心線程數(shù) + 非核心線程數(shù)

long keepAliveTime：非核心線程空閑超時時間

  keepAliveTime即為空閑線程允許的最大的存活時間。如果一個非核心線程空閑狀態(tài)的時長超過keepAliveTime了，就會被銷毀掉。注意：如果設(shè)置allowCoreThreadTimeOut = true，就變成核心線程超時銷毀了。

TimeUnit unit：是keepAliveTime 的單位

TimeUnit 是一個枚舉類型，列舉如下：

單位

單位 說明 NANOSECONDS 1微毫秒 = 1微秒 / 1000 MICROSECONDS 1微秒 = 1毫秒 / 1000 MILLISECONDS 1毫秒 = 1秒 /1000 SECONDS 秒 MINUTES 分 HOURS 小時 DAYS 天

BlockingQueue workQueue：存放任務(wù)的阻塞隊列

  當核心線程都在工作的時候，新提交的任務(wù)就會被添加到這個工作阻塞隊列中進行排隊等待；如果阻塞隊列也滿了，線程池就新建非核心線程去執(zhí)行任務(wù)。workQueue維護的是等待執(zhí)行的Runnable對象。常用的 workQueue 類型：（無界隊列、有界隊列、同步移交隊列）

SynchronousQueue：同步移交隊列，適用于非常大的或者無界的線程池，可以避免任務(wù)排隊，SynchronousQueue隊列接收到任務(wù)后，會直接將任務(wù)從生產(chǎn)者移交給工作者線程，這種移交機制高效。它是一種不存儲元素的隊列，任務(wù)不會先放到隊列中去等線程來取，而是直接移交給執(zhí)行的線程。只有當線程池是無界的或可以拒絕任務(wù)的時候，SynchronousQueue隊列的使用才有意義，maximumPoolSize 一般指定成 Integer.MAX_VALUE，即無限大。要將一個元素放入SynchronousQueue，就需要有另一個線程在等待接收這個元素。若沒有線程在等待，并且線程池的當前線程數(shù)小于最大值，則ThreadPoolExecutor就會新建一個線程；否則，根據(jù)飽和策略，拒絕任務(wù)。newCachedThreadPool默認使用的就是這種同步移交隊列。吞吐量高于LinkedBlockingQueue。

LinkedBlockingQueue：基于鏈表結(jié)構(gòu)的阻塞隊列，F(xiàn)IFO原則排序。當任務(wù)提交過來，若當前線程數(shù)小于corePoolSize核心線程數(shù)，則線程池新建核心線程去執(zhí)行任務(wù)；若當前線程數(shù)等于corePoolSize核心線程數(shù)，則進入工作隊列進行等待。LinkedBlockingQueue隊列沒有最大值限制，只要任務(wù)數(shù)超過核心線程數(shù)，都會被添加到隊列中，這就會導(dǎo)致總線程數(shù)永遠不會超過 corePoolSize，所以maximumPoolSize 是一個無效設(shè)定。newFixedThreadPool和newSingleThreadPool默認是使用的是無界LinkedBlockingQueue隊列。吞吐量高于ArrayBlockingQueue。

ArrayBlockingQueue：基于數(shù)組結(jié)構(gòu)的有界阻塞隊列，可以設(shè)置隊列上限值，F(xiàn)IFO原則排序。當任務(wù)提交時，若當前線程小于corePoolSize核心線程數(shù)，則新建核心線程執(zhí)行任務(wù)；若當先線程數(shù)等于corePoolSize核心線程數(shù)，則進入隊列排隊等候；若隊列的任務(wù)數(shù)也排滿了，則新建非核心線程執(zhí)行任務(wù)；若隊列滿了且總線程數(shù)達到了maximumPoolSize最大線程數(shù)，則根據(jù)飽和策略進行任務(wù)的拒絕。

DelayQueue：延遲隊列，隊列內(nèi)的元素必須實現(xiàn) Delayed 接口。當任務(wù)提交時，入隊列后只有達到指定的延時時間，才會執(zhí)行任務(wù)

PriorityBlockingQueue：優(yōu)先級阻塞隊列，根據(jù)優(yōu)先級執(zhí)行任務(wù)，優(yōu)先級是通過自然排序或者是Comparator定義實現(xiàn)。注意： 只有當任務(wù)相互獨立沒有任何依賴的時候，線程池或工作隊列設(shè)置有界是合理的；若任務(wù)之間存在依賴性，需要使用無界的

線程池，如newCachedThreadPool，否則有可能會導(dǎo)致死鎖問題。

ThreadFactory threadFactory

  創(chuàng)建線程的方式，這是一個接口，你 new 他的時候需要實現(xiàn)他的 Thread newThread(Runnable r) 方法，一般用不上，

RejectedExecutionHandler handler：飽和策略拋出異常專用，當隊列和最大線程池都滿了之后的飽和策略。

線程池工作流程

一般流程即為：創(chuàng)建worker線程；添加任務(wù)入workQueue隊列；worker線程執(zhí)行任務(wù)。

當一個任務(wù)被添加進線程池時：

1.當前線程數(shù)量未達到 corePoolSize，則新建一個線程(核心線程)執(zhí)行任務(wù)

2.當前線程數(shù)量達到了 corePoolSize，則將任務(wù)移入阻塞隊列等待，讓空閑線程處理；

3.當阻塞隊列已滿，新建線程(非核心線程)執(zhí)行任務(wù)

4.當阻塞隊列已滿，總線程數(shù)又達到了 maximumPoolSize，就會按照拒絕策略處理無法執(zhí)行的任務(wù)，比如RejectedExecutionHandler拋出異常。

這邊，為了大家能夠更好的去理解這塊的流程，我們舉一個例子。生活中我們經(jīng)常會去打一些公司的咨詢電話或者是一些特定機構(gòu)的投訴電話，而那個公司或者機構(gòu)的客服中心就是一個線程池，正式員工的客服小姐姐就好比是核心線程，比如有6個客服小姐姐。

5. 當用戶的電話打進到公司的客服中心的時候（提交任務(wù)）；

6. 客服中心會調(diào)度客服小姐姐去接聽電話（創(chuàng)建線程執(zhí)行任務(wù)），如果接聽的電話超過了6個，6個客服小姐姐都在接聽的工作狀態(tài)了（核心線程池滿了），這時客服中心會有一個電話接聽等待通道（進入任務(wù)隊列等待），就是我們經(jīng)常聽到的“您的通話在排隊，前面排隊n人。”

7. 當然，這個電話接聽等待通道也是有上限的，當超過這個上限的時候（任務(wù)隊列滿了），客服中心就會立即安排外協(xié)員工（非核心線程），也就是非正式員工去接聽額外的電話（任務(wù)隊列滿了，正式和非正式員工數(shù)量>總?cè)蝿?wù)數(shù)，線程池創(chuàng)建非核心線程去執(zhí)行任務(wù)）。

8. 當用戶電話數(shù)激增，客服中心控制臺發(fā)現(xiàn)這個時候正式員工和外協(xié)員工的總和已經(jīng)滿足不了這些用戶電話接入了（總線程池滿），就開始根據(jù)一些公司電話接聽規(guī)則去拒絕這些電話（按照拒絕策略處理無法執(zhí)行的任務(wù)）

線程池狀態(tài)

RUNNING：運行狀態(tài)，指可以接受任務(wù)并執(zhí)行隊列里的任務(wù)。

SHUTDOWN：調(diào)用了 shutdown() 方法，不再接受新任務(wù)，但隊列里的任務(wù)會執(zhí)行完畢。

STOP：指調(diào)用了 shutdownNow() 方法，不再接受新任務(wù)，所有任務(wù)都變成STOP狀態(tài)，不管是否正在執(zhí)行。該操作會拋棄阻塞隊列里的所有任務(wù)并中斷所有正在執(zhí)行任務(wù)。

TIDYING：所有任務(wù)都執(zhí)行完畢，程序調(diào)用 shutdown()/shutdownNow() 方法都會將線程更新為此狀態(tài)，若調(diào)用shutdown()，則等執(zhí)行任務(wù)全部結(jié)束，隊列即為空，變成TIDYING狀態(tài)；調(diào)用shutdownNow()方法后，隊列任務(wù)清空且正在執(zhí)行的任務(wù)中斷后，更新為TIDYING狀態(tài)。

TERMINATED：終止狀態(tài)，當線程執(zhí)行 terminated() 后會更新為這個狀態(tài)。

線程池源碼

線程池核心接口

ThreadPoolExecutor，在java.util.concurrent下。

/** * Creates a new {@code ThreadPoolExecutor} with the given initial * parameters. * * @param corePoolSize the number of threads to keep in the pool, even * if they are idle, unless {@code allowCoreThreadTimeOut} is set * @param maximumPoolSize the maximum number of threads to allow in the * pool * @param keepAliveTime when the number of threads is greater than * the core, this is the maximum time that excess idle threads * will wait for new tasks before terminating. * @param unit the time unit for the {@code keepAliveTime} argument * @param workQueue the queue to use for holding tasks before they are * executed. This queue will hold only the {@code Runnable} * tasks submitted by the {@code execute} method. * @param threadFactory the factory to use when the executor * creates a new thread * @param handler the handler to use when execution is blocked * because the thread bounds and queue capacities are reached * @throws IllegalArgumentException if one of the following holds:<br> * {@code corePoolSize < 0}<br> * {@code keepAliveTime < 0}<br> * {@code maximumPoolSize <= 0}<br> * {@code maximumPoolSize < corePoolSize} * @throws NullPointerException if {@code workQueue} * or {@code threadFactory} or {@code handler} is null */ public ThreadPoolExecutor(int corePoolSize, //核心線程數(shù) int maximumPoolSize, //最大線程數(shù) long keepAliveTime, //空閑線程存活時間 TimeUnit unit, //存活時間單位 BlockingQueue<Runnable> workQueue, //任務(wù)的阻塞隊列 ThreadFactory threadFactory, //新線程的產(chǎn)生方式 RejectedExecutionHandler handler //拒絕策略) { if (corePoolSize < 0 || maximumPoolSize <= 0 || maximumPoolSize < corePoolSize || keepAliveTime < 0) throw new IllegalArgumentException(); if (workQueue == null || threadFactory == null || handler == null) throw new NullPointerException(); this.acc = System.getSecurityManager() == null ?null :AccessController.getContext(); this.corePoolSize = corePoolSize; this.maximumPoolSize = maximumPoolSize; this.workQueue = workQueue; this.keepAliveTime = unit.toNanos(keepAliveTime); this.threadFactory = threadFactory; this.handler = handler; }

ThreadPoolExecutor 繼承 AbstractExecutorService；AbstractExecutorService 實現(xiàn) ExecutorService， ExecutorService 繼承 Executor

public class ThreadPoolExecutor extends AbstractExecutorService {}public abstract class AbstractExecutorService implements ExecutorService {}public interface ExecutorService extends Executor {}

線程池構(gòu)造方法

1）5參數(shù)構(gòu)造器

// 5參數(shù)構(gòu)造器public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue)

2）6參數(shù)構(gòu)造器-1

// 6參數(shù)構(gòu)造器-1public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory)

3）6參數(shù)構(gòu)造器-2

// 6參數(shù)構(gòu)造器-2public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,RejectedExecutionHandler handler)

4）7參數(shù)構(gòu)造器

// 7參數(shù)構(gòu)造器public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler)

四種線程池

常規(guī)用法

//創(chuàng)建固定數(shù)目線程的線程池Executors.newFixedThreadPool(200);

//創(chuàng)建一個無限線程的線程池，無需等待隊列，任務(wù)提交即執(zhí)行Executors.newCachedThreadPool()

//創(chuàng)建有且僅有一個線程的線程池Executors.newSingleThreadExecutor();

newCachedThreadPool()：可緩存線程池

介紹

newCachedThreadPool將創(chuàng)建一個可緩存的線程，如果當前線程數(shù)超過處理任務(wù)時，回收空閑線程；當需求增加時，可以添加新線程去處理任務(wù)。

線程數(shù)無限制，corePoolSize數(shù)值為0， maximumPoolSize 的數(shù)值都是為 Integer.MAX_VALUE。 若線程未回收，任務(wù)到達時，會復(fù)用空閑線程；若無空閑線程，則新建線程執(zhí)行任務(wù)。 因為復(fù)用性，一定程序減少頻繁創(chuàng)建/銷毀線程，減少系統(tǒng)開銷。 工作隊列可以選用SynchronousQueue。

創(chuàng)建方法

ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

源碼

public static ExecutorService newCachedThreadPool() { return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()); }

newFixedThreadPool()：定長線程池

介紹

newFixedThreadPool創(chuàng)建一個固定長度的線程池，每次提交一個任務(wù)的時候就會創(chuàng)建一個新的線程，直到達到線程池的最大數(shù)量限制。

定長，可以控制線程最大并發(fā)數(shù)， corePoolSize 和 maximumPoolSize 的數(shù)值都是nThreads。 超出的線程會在隊列中等待。 工作隊列可以選用LinkedBlockingQueue。

創(chuàng)建方法

ExecutorService fixedThreadPool = Executors.newFixedThreadPool(int nThreads);

源碼

public static ExecutorService newFixedThreadPool(int nThreads) { return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()); }

newScheduledThreadPool()：定時線程池

介紹

newScheduledThreadPool創(chuàng)建一個固定長度的線程池，并且以延遲或者定時的方式去執(zhí)行任務(wù)。

創(chuàng)建方法：

ExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(int corePoolSize);

源碼

public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) { return new ScheduledThreadPoolExecutor(corePoolSize); } public ScheduledThreadPoolExecutor(int corePoolSize) { super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS, new DelayedWorkQueue()); }

newSingleThreadExecutor()：單線程化的線程池

介紹

newSingleThreadExecutor顧名思義，是一個單線程的Executor，只創(chuàng)建一個工作線程執(zhí)行任務(wù)，若這個唯一的線程異常故障了，會新建另一個線程來替代，newSingleThreadExecutor可以保證任務(wù)依照在工作隊列的排隊順序來串行執(zhí)行。

有且僅有一個工作線程執(zhí)行任務(wù)； 所有任務(wù)按照工作隊列的排隊順序執(zhí)行，先進先出的順序。 單個線程的線程池就是線程池中只有一個線程負責任務(wù)，所以 corePoolSize 和 maximumPoolSize 的數(shù)值都是為 1；當這個線程出現(xiàn)任何異常后，線程池會自動創(chuàng)建一個線程，始終保持線程池中有且只有一個存活的線程。 工作隊列可以選用LinkedBlockingQueue。

創(chuàng)建方法

ExecutorService singleThreadPool = Executors.newSingleThreadPool();

源碼

public static ExecutorService newSingleThreadExecutor() { return new FinalizableDelegatedExecutorService (new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>())); } static class FinalizableDelegatedExecutorService extends DelegatedExecutorService { FinalizableDelegatedExecutorService(ExecutorService executor) { super(executor); } protected void finalize() { super.shutdown(); } }

execute()方法

介紹

ThreadPoolExecutor.execute(Runnable command)方法，即可向線程池內(nèi)添加一個任務(wù)

execute源碼

/** * Executes the given task sometime in the future. The task * may execute in a new thread or in an existing pooled thread. * * If the task cannot be submitted for execution, either because this * executor has been shutdown or because its capacity has been reached, * the task is handled by the current {@code RejectedExecutionHandler}. * * @param command the task to execute * @throws RejectedExecutionException at discretion of * {@code RejectedExecutionHandler}, if the task * cannot be accepted for execution * @throws NullPointerException if {@code command} is null */ public void execute(Runnable command) { if (command == null) throw new NullPointerException(); /* * Proceed in 3 steps: * * 1. If fewer than corePoolSize threads are running, try to * start a new thread with the given command as its first * task. The call to addWorker atomically checks runState and * workerCount, and so prevents false alarms that would add * threads when it shouldn’t, by returning false. * * 2. If a task can be successfully queued, then we still need * to double-check whether we should have added a thread * (because existing ones died since last checking) or that * the pool shut down since entry into this method. So we * recheck state and if necessary roll back the enqueuing if * stopped, or start a new thread if there are none. * * 3. If we cannot queue task, then we try to add a new * thread. If it fails, we know we are shut down or saturated * and so reject the task. *///獲取當前線程池的狀態(tài) int c = ctl.get();//若當前線程數(shù)量小于corePoolSize，則創(chuàng)建一個新的線程 if (workerCountOf(c) < corePoolSize) { if (addWorker(command, true))return; c = ctl.get(); }//判斷當前線程是否處于運行狀態(tài)，且寫入任務(wù)阻塞隊列是否成功 if (isRunning(c) && workQueue.offer(command)) { int recheck = ctl.get();//再次獲取線程狀態(tài)進行雙重檢查；如果線程變成非運行狀態(tài)，則從阻塞隊列移除任務(wù)； if (! isRunning(recheck) && remove(command))//執(zhí)行拒絕策略reject(command);//若當前線程池為空，則新建一個線程 else if (workerCountOf(recheck) == 0)addWorker(null, false); }//當前線程為非運行狀態(tài)并且嘗試新建線程，若失敗則執(zhí)行拒絕策略。 else if (!addWorker(command, false)) reject(command); }

流程分析

1）若當前線程數(shù)小于corePoolSize，則調(diào)用addWorker()方法創(chuàng)建線程執(zhí)行任務(wù)。

2）若當前線程不小于corePoolSize，則將任務(wù)添加到workQueue隊列，等待空閑線程來執(zhí)行。

3）若隊列里的任務(wù)數(shù)到達上限，且當前運行線程小于maximumPoolSize，任務(wù)入workQueue隊列失敗，新建線程執(zhí)行任務(wù)；

4）若創(chuàng)建線程也失敗(隊列任務(wù)數(shù)到達上限，且當前線程數(shù)達到了maximumPoolSize)，對于新加入的任務(wù)，就會調(diào)用reject()(內(nèi)部調(diào)用handler)拒絕接受任務(wù)。

Q&A

兩種關(guān)閉線程池的區(qū)別

shutdown()： 執(zhí)行后停止接受新任務(wù)，會把隊列的任務(wù)執(zhí)行完畢。

shutdownNow()： 執(zhí)行后停止接受新任務(wù)，但會中斷所有的任務(wù)（不管是否正在執(zhí)行中），將線程池狀態(tài)變?yōu)?STOP狀態(tài)。

拒絕策略有哪些？ThreadPoolExecutor的飽和策略可以通過調(diào)用setRejectedExecutionHandler來修改。JDK提供了幾種不同的

RejectedExecutionHandler實現(xiàn)，每種實現(xiàn)都包含有不同的飽和策略：AbortPolicy、CallerRunsPolicy、DiscardPolicy和DiscardOldestPolicy。

拒絕策略如下：

CallerRunsPolicy : 調(diào)用線程處理任務(wù) AbortPolicy : 拋出異常 DiscardPolicy : 直接丟棄 DiscardOldestPolicy : 丟棄隊列中最老的任務(wù)，執(zhí)行新任務(wù)

RejectedExecutionHandler rejected = null;

//默認策略，阻塞隊列滿，則丟任務(wù)、拋出異常rejected = new ThreadPoolExecutor.AbortPolicy();

//阻塞隊列滿，則丟任務(wù)，不拋異常rejected = new ThreadPoolExecutor.DiscardPolicy();

//刪除隊列中最舊的任務(wù)（最早進入隊列的任務(wù)），嘗試重新提交新的任務(wù)rejected = new ThreadPoolExecutor.DiscardOldestPolicy();

//隊列滿，不丟任務(wù)，不拋異常，若添加到線程池失敗，那么主線程會自己去執(zhí)行該任務(wù)rejected = new ThreadPoolExecutor.CallerRunsPolicy();

（1）AbortPolicy、DiscardPolicy和DiscardOldestPolicy

  AbortPolicy是默認的飽和策略，就是中止任務(wù)，該策略將拋出RejectedExecutionException。調(diào)用者可以捕獲這個異常然后去編寫代碼處理異常。

  當新提交的任務(wù)無法保存到隊列中等待執(zhí)行時，DiscardPolicy會悄悄的拋棄該任務(wù)。

  DiscardOldestPolicy則會拋棄最舊的（下一個將被執(zhí)行的任務(wù)），然后嘗試重新提交新的任務(wù)。如果工作隊列是那個優(yōu)先級隊列時，搭配DiscardOldestPolicy飽和策略會導(dǎo)致優(yōu)先級最高的那個任務(wù)被拋棄，所以兩者不要組合使用。

（2）CallerRunsPolicy

CallerRunsPolicy是“調(diào)用者運行”策略，實現(xiàn)了一種調(diào)節(jié)機制 。它不會拋棄任務(wù)，也不會拋出異常。 而是將任務(wù)回退到調(diào)用者。它不會在線程池中執(zhí)行任務(wù)，而是在一個調(diào)用了execute的線程中執(zhí)行該任務(wù)。在線程滿后，新任務(wù)將交由調(diào)用線程池execute方法的主線程執(zhí)行，而由于主線程在忙碌，所以不會執(zhí)行accept方法，從而實現(xiàn)了一種平緩的性能降低。

  當工作隊列被填滿后，沒有預(yù)定義的飽和策略來阻塞execute（除了拋棄就是中止還有去讓調(diào)用者去執(zhí)行）。然而可以通過Semaphore來限制任務(wù)的到達率。

以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持好吧啦網(wǎng)。