概述

FutureTask?可取消的異步任務，提供Future的基礎實現(xiàn)，并實現(xiàn)了Runnable接口。FutureTask包含了取消與啟動計算的方法，查詢計算是否完成以及檢索計算結果的方法。只有在計算完成才能檢索到結果，調用get()方法時如果任務還沒有完成將會阻塞調用線程至到任務完成。一旦計算完成就不能重新開始與取消計算，但可以調用runAndReset()重置狀態(tài)后再重新計算。

類圖

?

?

FutureTask實現(xiàn)了RunnableFuture接口，而RunnableFuture接口擴展自Future?Runnable接口，在創(chuàng)建FutureTask時可以使用Callable接口的實例或者Lambda表達式，也可以使用Runnable的實例，但內部還是會使用適配器模式轉換成Callable實例類型。

創(chuàng)建第一個任務

使用Callable創(chuàng)建一個FutureTask實例：

FutureTask<Boolean> future = new FutureTask<>(new Callable<Boolean>() {
   @Override
   public Boolean call() throws Exception {
     return true;
   }
 });

通過new一個對象的方法可以直接創(chuàng)建一個FutureTask實例，如果直接調用run方法將直接在當前線程中運行，不會開啟新線程。

使用ExecutorService或者線程可以讓FutureTask進行托管進行，示例如下：

//托管給線程池處理
Future<?> futureResult = Executors.newCachedThreadPool().submit(future);
//托管給單獨線程處理
new Thread(future).start();

因為FutureTask繼承了Runnable接口，所以它可以通過new Thread()的方式進行運行，再由future變量來檢索結果值或者取消任務等操作，通過線程池托管的方式也可以適用。

取消任務

遇到特殊情況時需要對沒有運行的或者已經運行的任務進行取消操作，這時可以調用cancel()方法，取消方法有一個布爾類型的參數(shù)mayInterruptIfRunning；當值為ture時將嘗試中斷托管的線程(調用托管線程的interrupt嘗試中斷)。

取消任務使用的是線程的中斷操作，如果任務是可取消的，在任務中存在阻塞線程的地方需要加上InterruptedException的異常捕獲來處理中斷異常或者在任務可取消點使用Thread.currentThread().isInterrupted()方法來判斷任務是否已經發(fā)送的中斷請求以正常取消任務。

檢索結果值

使用FutureTask的一個重要目的是為了能獲取到任務的結果值，使用Callable使用一個任務調用點時可以在任務中返回一個引用類型。

在FutureTask內部使用outcome變量存儲Callable的結果，調用FutureTask.get()方法將檢索結果值，但get()方法也會阻塞調用線程直到任務執(zhí)行完成或者取消。

get()方法還可以通過設置超時時間來指定等待的時長，超過等待時間后將會拋出TimeoutException異常。

總結

使用FutureTask可以完成任務的取消、檢查結果值，這兩項也是FutureTask的特色，但FutureTask的底層還是托管給Thread完成；相對于Thread檢查結果值會更新的方便，不再需要管理線程執(zhí)行的狀態(tài)與值。

在使用cancel方法需要注意任務是否可以取消，在任務內部需要使用Thread.currentThread().isInterrupted()檢查中斷狀態(tài)并在Thread.sleep()?condition.wait()?Thread.join()?Thread.wait()使用線程進行阻塞以及可中斷的I/O操作方法中捕獲InterruptedException異常以避免不必要的情況發(fā)生，在大多數(shù)任務中是不應該被中斷的，所以最好在可中斷的任務中設置好檢查點；在任務線程會被阻塞點捕獲InterruptedException異常，根據(jù)情況判斷是否需要取消任務。

?

?

?

?