知識星球
原文出處http://cmsblogs.com/ 『chenssy』
經歷了Java記憶體模型、JUC基礎之AQS、CAS、Lock、併發工具類、併發容器、阻塞佇列、atomic類後，我們開始JUC的最後一部分：執行緒池。在這個部分你將瞭解到下麵幾個部分：
-
執行緒池的基礎架構
-
執行緒池的原理分析
-
執行緒池核心類的原始碼分析
-
執行緒池調優
Executor
我們先看執行緒池的基礎架構圖：
Executor
Executor，任務的執行者，執行緒池框架中幾乎所有類都直接或者間接實現Executor介面，它是執行緒池框架的基礎。Executor提供了一種將“任務提交”與“任務執行”分離開來的機制，它僅提供了一個Execute()方法用來執行已經提交的Runnable任務。
public interface Executor {
void execute(Runnable command);
}
ExcutorService
繼承Executor，它是“執行者服務”介面，它是為”執行者介面Executor”服務而存在的。準確的地說，ExecutorService提供了”將任務提交給執行者的介面(submit方法)”，”讓執行者執行任務(invokeAll, invokeAny方法)”的介面等等。
public interface ExecutorService extends Executor {
/**
* 啟動一次順序關閉，執行以前提交的任務，但不接受新任務
*/
void shutdown();
/**
* 試圖停止所有正在執行的活動任務，暫停處理正在等待的任務，並傳回等待執行的任務串列
*/
List<Runnable> shutdownNow();
/**
* 如果此執行程式已關閉，則傳回 true。
*/
boolean isShutdown();
/**
* 如果關閉後所有任務都已完成，則傳回 true
*/
boolean isTerminated();
/**
* 請求關閉、發生超時或者當前執行緒中斷，無論哪一個首先發生之後，都將導致阻塞，直到所有任務完成執行
*/
boolean awaitTermination(long timeout, TimeUnit unit)
throws InterruptedException;
/**
* 提交一個傳回值的任務用於執行，傳回一個表示任務的未決結果的 Future
*/
<T> Future<T> submit(Callable<T> task);
/**
* 提交一個 Runnable 任務用於執行，並傳回一個表示該任務的 Future
*/
<T> Future<T> submit(Runnable task, T result);
/**
* 提交一個 Runnable 任務用於執行，並傳回一個表示該任務的 Future
*/
Future> submit(Runnable task);
/**
* 執行給定的任務，當所有任務完成時，傳回保持任務狀態和結果的 Future 串列
*/
<T> List<Future<T>> invokeAll(Collection extends Callable<T>> tasks)
throws InterruptedException;
/**
* 執行給定的任務，當所有任務完成或超時期滿時（無論哪個首先發生），傳回保持任務狀態和結果的 Future 串列
*/
<T> List<Future<T>> invokeAll(Collection extends Callable<T>> tasks,
long timeout, TimeUnit unit)
throws InterruptedException;
/**
* 執行給定的任務，如果某個任務已成功完成（也就是未丟擲異常），則傳回其結果
*/
<T> T invokeAny(Collection extends Callable<T>> tasks)
throws InterruptedException, ExecutionException;
/**
* 執行給定的任務，如果在給定的超時期滿前某個任務已成功完成（也就是未丟擲異常），則傳回其結果
*/
<T> T invokeAny(Collection extends Callable<T>> tasks,
long timeout, TimeUnit unit)
throws InterruptedException, ExecutionException, TimeoutException;
}
AbstractExecutorService
抽象類，實現ExecutorService介面，為其提供預設實現。AbstractExecutorService除了實現ExecutorService介面外，還提供了newTaskFor()方法傳回一個RunnableFuture，在執行的時候，它將呼叫底層可呼叫任務，作為 Future 任務，它將生成可呼叫的結果作為其結果，併為底層任務提供取消操作。
ScheduledExecutorService
繼承ExcutorService，為一個“延遲”和“定期執行”的ExecutorService。他提供了一些如下幾個方法安排任務在給定的延時執行或者週期性執行。
// 建立並執行在給定延遲後啟用的 ScheduledFuture。
<V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit)
// 建立並執行在給定延遲後啟用的一次性操作。
ScheduledFuture> schedule(Runnable command, long delay, TimeUnit unit)
// 建立並執行一個在給定初始延遲後首次啟用的定期操作，後續操作具有給定的週期；
//也就是將在 initialDelay 後開始執行，然後在 initialDelay+period 後執行，接著在 initialDelay + 2 * period 後執行，依此類推。
ScheduledFuture> scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)
// 建立並執行一個在給定初始延遲後首次啟用的定期操作，隨後，在每一次執行終止和下一次執行開始之間都存在給定的延遲。
ScheduledFuture> scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)
ThreadPoolExecutor
大名鼎鼎的“執行緒池”，後續做詳細介紹。
ScheduledThreadPoolExecutor
ScheduledThreadPoolExecutor繼承ThreadPoolExecutor並且實現ScheduledExecutorService介面，是兩者的集大成者，相當於提供了“延遲”和“週期執行”功能的ThreadPoolExecutor。
Executors
靜態工廠類，提供了Executor、ExecutorService、ScheduledExecutorService、ThreadFactory 、Callable 等類的靜態工廠方法，透過這些工廠方法我們可以得到相對應的物件。
-
建立並傳回設定有常用配置字串的 ExecutorService 的方法。
-
建立並傳回設定有常用配置字串的 ScheduledExecutorService 的方法。
-
建立並傳回“包裝的”ExecutorService 方法，它透過使特定於實現的方法不可訪問來禁用重新配置。
-
建立並傳回 ThreadFactory 的方法，它可將新建立的執行緒設定為已知的狀態。
-
建立並傳回非閉包形式的 Callable 的方法，這樣可將其用於需要 Callable 的執行方法中。
Future
Future介面和實現Future介面的FutureTask代表了執行緒池的非同步計算結果。
AbstractExecutorService提供了newTaskFor()方法傳回一個RunnableFuture，除此之外當我們把一個Runnable或者Callable提交給（submit()）ThreadPoolExecutor或者ScheduledThreadPoolExecutor時，他們則會向我們傳回一個FutureTask物件。如下：
protected <T> RunnableFuture<T> newTaskFor(Runnable runnable, T value) {
return new FutureTask<T>(runnable, value);
}
protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable) {
return new FutureTask<T>(callable);
}
<T> Future<T> submit(Callable<T> task)
<T> Future<T> submit(Runnable task, T result)
Future<> submit(Runnable task)
Future
作為非同步計算的頂層介面，Future對具體的Runnable或者Callable任務提供了三種操作：執行任務的取消、查詢任務是否完成、獲取任務的執行結果。其介面定義如下：
public interface Future<V> {
/**
* 試圖取消對此任務的執行
* 如果任務已完成、或已取消，或者由於某些其他原因而無法取消，則此嘗試將失敗。
* 當呼叫 cancel 時，如果呼叫成功，而此任務尚未啟動，則此任務將永不執行。
* 如果任務已經啟動，則 mayInterruptIfRunning 引數確定是否應該以試圖停止任務的方式來中斷執行此任務的執行緒
*/
boolean cancel(boolean mayInterruptIfRunning);
/**
* 如果在任務正常完成前將其取消，則傳回 true
*/
boolean isCancelled();
/**
* 如果任務已完成，則傳回 true
*/
boolean isDone();
/**
* 如有必要，等待計算完成，然後獲取其結果
*/
V get() throws InterruptedException, ExecutionException;
/**
* 如有必要，最多等待為使計算完成所給定的時間之後，獲取其結果（如果結果可用）
*/
V get(long timeout, TimeUnit unit)
throws InterruptedException, ExecutionException, TimeoutException;
}
RunnableFuture
繼承Future、Runnable兩個介面，為兩者的合體，即所謂的Runnable的Future。提供了一個run()方法可以完成Future並允許訪問其結果。
public interface RunnableFuture<V> extends Runnable, Future<V> {
//在未被取消的情況下，將此 Future 設定為計算的結果
void run();
}
FutureTask
實現RunnableFuture介面，既可以作為Runnable被執行，也可以作為Future得到Callable的傳回值。
END
