引導(dǎo)

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

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

線程池介紹線程池概述

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

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

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

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

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

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

核心線程默認(rèn)情況下會一直存活在線程池中，即使這個核心線程不工作(空閑狀態(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 是一個枚舉類型，列舉如下：

單位

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

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

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

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

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

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

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

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

ThreadFactory threadFactory

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

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

線程池工作流程

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

當(dāng)一個任務(wù)被添加進(jìn)線程池時：

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

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

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

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

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

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

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

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

8. 當(dāng)用戶電話數(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：終止?fàn)顟B(tài)，當(dāng)線程執(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)造器-1
public ThreadPoolExecutor(int corePoolSize,
		       	int maximumPoolSize,
			long keepAliveTime,
			TimeUnit unit,
			BlockingQueue<Runnable> workQueue,
			ThreadFactory threadFactory)

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

// 6參數(shù)構(gòu)造器-2
public 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)建一個可緩存的線程，如果當(dāng)前線程數(shù)超過處理任務(wù)時，回收空閑線程；當(dāng)需求增加時，可以添加新線程去處理任務(wù)。

• 線程數(shù)無限制，corePoolSize數(shù)值為0， maximumPoolSize 的數(shù)值都是為 Integer.MAX_VALUE。
• 若線程未回收，任務(wù)到達(dá)時，會復(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)建一個新的線程，直到達(dá)到線程池的最大數(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í)行，先進(jìn)先出的順序。
• 單個線程的線程池就是線程池中只有一個線程負(fù)責(zé)任務(wù)，所以 corePoolSize 和 maximumPoolSize 的數(shù)值都是為 1；當(dāng)這個線程出現(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.
     */
	//獲取當(dāng)前線程池的狀態(tài)
    int c = ctl.get();
	//若當(dāng)前線程數(shù)量小于corePoolSize，則創(chuàng)建一個新的線程
    if (workerCountOf(c) < corePoolSize) {
      if (addWorker(command, true))
        return;
      c = ctl.get();
    }
	//判斷當(dāng)前線程是否處于運行狀態(tài)，且寫入任務(wù)阻塞隊列是否成功
    if (isRunning(c) && workQueue.offer(command)) {
      int recheck = ctl.get();
	//再次獲取線程狀態(tài)進(jìn)行雙重檢查；如果線程變成非運行狀態(tài)，則從阻塞隊列移除任務(wù)；
      if (! isRunning(recheck) && remove(command))
	//執(zhí)行拒絕策略
        reject(command);
	//若當(dāng)前線程池為空，則新建一個線程
      else if (workerCountOf(recheck) == 0)
        addWorker(null, false);
    }
	//當(dāng)前線程為非運行狀態(tài)并且嘗試新建線程，若失敗則執(zhí)行拒絕策略。
    else if (!addWorker(command, false))
      reject(command);
  }

流程分析

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

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

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

4）若創(chuàng)建線程也失敗(隊列任務(wù)數(shù)到達(dá)上限，且當(dāng)前線程數(shù)達(dá)到了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;

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

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

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

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

（1）AbortPolicy、DiscardPolicy和DiscardOldestPolicy

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

  當(dāng)新提交的任務(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é)機(jī)制 。它不會拋棄任務(wù)，也不會拋出異常。 而是將任務(wù)回退到調(diào)用者。它不會在線程池中執(zhí)行任務(wù)，而是在一個調(diào)用了execute的線程中執(zhí)行該任務(wù)。在線程滿后，新任務(wù)將交由調(diào)用線程池execute方法的主線程執(zhí)行，而由于主線程在忙碌，所以不會執(zhí)行accept方法，從而實現(xiàn)了一種平緩的性能降低。

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

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評論