有時我寫了一篇有關Java Callable Future接口的文章，我們可以使用它來獲得線程的并發處理優勢，以及它們能夠將值返回給調用程序。

FutureTask是Future接口的基礎具體實現，并提供異步處理。 它包含啟動和取消任務的方法，以及可以返回FutureTask狀態（完成還是取消）的方法。 我們需要一個可調用的對象來創建未來的任務，然后我們可以使用Java線程池執行器來異步處理這些任務。

讓我們看一個帶有簡單程序的FutureTask示例。

由于FutureTask需要可調用對象，因此我們將創建一個簡單的Callable實現。

package com.journaldev.threads;import java.util.concurrent.Callable;public class MyCallable implements Callable<String> {private long waitTime;public MyCallable(int timeInMillis){this.waitTime=timeInMillis;}@Overridepublic String call() throws Exception {Thread.sleep(waitTime);//return the thread name executing this callable taskreturn Thread.currentThread().getName();}}

這是FutureTask方法的示例，它顯示了FutureTask的常用方法。

package com.journaldev.threads;import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.FutureTask; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException;public class FutureTaskExample {public static void main(String[] args) {MyCallable callable1 = new MyCallable(1000);MyCallable callable2 = new MyCallable(2000);FutureTask<String> futureTask1 = new FutureTask<String>(callable1);FutureTask<String> futureTask2 = new FutureTask<String>(callable2);ExecutorService executor = Executors.newFixedThreadPool(2);executor.execute(futureTask1);executor.execute(futureTask2);while (true) {try {if(futureTask1.isDone() && futureTask2.isDone()){System.out.println("Done");//shut down executor serviceexecutor.shutdown();return;}if(!futureTask1.isDone()){//wait indefinitely for future task to completeSystem.out.println("FutureTask1 output="+futureTask1.get());}System.out.println("Waiting for FutureTask2 to complete");String s = futureTask2.get(200L, TimeUnit.MILLISECONDS);if(s !=null){System.out.println("FutureTask2 output="+s);}} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}catch(TimeoutException e){//do nothing}}}}

當我們在上面的程序上運行時，您會注意到它一段時間不打印任何內容，因為FutureTask的get()方法等待任務完成，然后返回輸出對象。 還有一個重載方法也只能等待指定的時間，我們將它用于futureTask2。 還要注意，使用isDone()方法可確保在執行所有任務后終止程序。

上面程序的輸出將是：

FutureTask1 output=pool-1-thread-1 Waiting for FutureTask2 to complete Waiting for FutureTask2 to complete Waiting for FutureTask2 to complete Waiting for FutureTask2 to complete Waiting for FutureTask2 to complete FutureTask2 output=pool-1-thread-2 Done

因此，FutureTask沒有任何好處，但是當我們想要重寫某些Future接口方法并且不想實現Future接口的每個方法時，它就派上用場了。

參考： 開發者食譜博客上來自我們JCG合作伙伴 Pankaj Kumar的Java FutureTask示例程序 。

翻譯自: https://www.javacodegeeks.com/2013/07/java-futuretask-example-program.html

總結

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

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