有時我寫了一篇有關(guān)Java Callable Future接口的文章，我們可以使用它來獲得線程的并發(fā)處理優(yōu)勢，以及它們能夠?qū)⒅捣祷亟o調(diào)用程序。

FutureTask是Future接口的基礎(chǔ)具體實(shí)現(xiàn)，并提供異步處理。 它包含啟動和取消任務(wù)的方法，以及可以返回FutureTask狀態(tài)（完成還是取消）的方法。 我們需要一個可調(diào)用的對象來創(chuàng)建未來的任務(wù)，然后我們可以使用Java線程池執(zhí)行器來異步處理這些任務(wù)。

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

由于FutureTask需要可調(diào)用對象，因此我們將創(chuàng)建一個簡單的Callable實(shí)現(xiàn)。

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}}}}

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

上面程序的輸出將是：

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沒有任何好處，但是當(dāng)我們想要重寫某些Future接口方法并且不想實(shí)現(xiàn)Future接口的每個方法時，它就派上用場了。

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

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

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。