FutureTask使用

FutureTask介紹

FutureTask 表示一個異步運算的任務。FutureTask 里面可以傳入一個 Callable 的具體實現類，可以對這個異步運算的任務的結果進行等待獲取、判斷是否已經完成、取消任務等操作。

FutureTask實現接口

FutureTask實現了RunnableFuture接口，而接口RunnableFuture繼承了Runnable, Future。

public class FutureTask<V> implements RunnableFuture<V> public interface RunnableFuture<V> extends Runnable, Future<V>

FutureTask構造函數

FutureTask有兩個構造函數，分別可以接受Callable和Runnable的實現類。

public FutureTask(Callable<V> callable) {if (callable == null)throw new NullPointerException();this.callable = callable;this.state = NEW; // ensure visibility of callable }public FutureTask(Runnable runnable, V result) {this.callable = Executors.callable(runnable, result);this.state = NEW; // ensure visibility of callable }

FutureTask的使用

因為FutureTask實現了RunnableFuture接口，而接口RunnableFuture繼承了Runnable。所以可以使用Thread來start()，也可以使用線程池executor.execute()和executorService.submit()

又因為接口RunnableFuture繼承了 Future接口，我們可以通過FutureTask來獲取線程執行的結果。

public static void main(String[] args) {//創建一個FutureTaskFutureTask futureTask = new FutureTask(new Callable() {@Overridepublic Object call() throws Exception {System.out.println("執行call，并返回數值");return 5;}});//用線程池//Executor executor = Executors.newCachedThreadPool();//ExecutorService pool = Executors.newFixedThreadPool(5);//executor.execute(futureTask);//pool.submit(futureTask);//創建ThreadThread thread = new Thread(futureTask);//啟動線程thread.start();try {Integer result = (Integer) futureTask.get();System.out.println("獲得的線程執行結果:"+result);} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}}

結果

執行call，并返回數值 獲得的線程執行結果:5

總結

以上是生活随笔為你收集整理的FutureTask使用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。