線程池可以並發執行多個任務，有些時候，我們可能想要跟踪任務的執行結果，甚至在一定時間內，如果任務沒有執行完成，我們可能還想要取消任務的執行，為了支持這一特性，ThreadPoolExecutor提供了FutureTask 用於追踪任務的執行和取消。本篇介紹FutureTask的實現原理。
為了更好的理解FutureTask的實現原理，這裡先提供幾個重要接口和類的結構，如下圖所示：
ThreadPoolExecutor提供了submit接口用於提交任務，submit支持Runnable和Callable兩種不同的接口，為了提供統一的對外接口，jdk在內部把Runnable給包裝成了一個Callable，這一切是通過RunnableAdapter這個適配器來實現的。如下為RunnableAdapter的源碼：
static final class RunnableAdapter<T> implements Callable<T> { final Runnable task; final T result; RunnableAdapter(Runnable task, T result) { this.task = task; this.result = result; } public T call() { task.run(); return result; } }RunnableAdapter是Callable 的實現類，實現了call方法，而call方法僅僅是調用task.run(),然後return result，這樣就能夠確保在內部只需要統一處理Callable接口。
通過上一小節的了解，我們知道提交的Runnable任務在內部統一被轉換為Callable任務。查看submit方法的返回值，為一個Future，實際上這個Futrue為FutureTask實例，通過此實例，調用get方法，可以阻塞當前線程，直到任務運行完畢，返回結果。
整個調用鏈條如下所示：
worker thread -> futureTask.run() -> callable.call() -> task.run()
如果提交的是Callable任務，則只有前面三個調用。
為了更好的展示整個流程，下面舉例演示一遍執行流程。
1、 向線程池submit一個Callable任務(Runnable也會被轉為Callable)， 這時候Callable被傳入一個FutureTask實例中，如下所示：
2、線程池使用一個線程，執行這個FutureTask 任務，
線程執行任務過程比較簡單，最終會調用Callable.call()或者是Runnable.run()方法，然後得到一個結果，把結果存儲在FutureTask實例的outcome屬性中，同時把狀態修改為NORMAL，表明任務已經執行完畢，可以獲取結果了。
我們假設在執行callable.call()過程中有多個線程調用了同個FutureTask實例的get方法，這時候，這些線程會被阻塞，存於一個棧中， 如下圖所示：
線程1，2，3調用FutureTask.get方法，由於任務未執行結束，這時候，三個線程都將被阻塞休眠，FutureTask中有一個棧，用於存放等待線程，棧頂指針為FutureTask.waiters引用，當任務執行完畢後，會迭代喚醒整個棧中的線程，這時候，各個線程都將被喚醒，並且可以順利拿到任務的執行結果(執行結果存於FutureTask.outcome) 。
FutureTask還支持任務的取消功能，這一切都是通過FutureTask的state狀態來協調多個線程的。
FutureTask接口是一種實現機制，提供我們對任務的執行的跟踪以及控制，相比於線程池本身，比較簡單，相信不難理解。
以上就是本文關於Java線程池FutureTask實現原理詳解的全部內容，希望對大家有所幫助。感興趣的朋友可以繼續參閱本站其他相關專題，如有不足之處，歡迎留言指出。感謝朋友們對本站的支持！