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

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

讓我們看一個(gè)帶有簡(jiǎn)單程序的FutureTask示例。

由于FutureTask需要可調(diào)用對(duì)象，因此我們將創(chuàng)建一個(gè)簡(jiǎn)單的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)我們?cè)谏厦娴某绦蛏线\(yùn)行時(shí)，您會(huì)注意到它一段時(shí)間不打印任何內(nèi)容，因?yàn)镕utureTask的get()方法等待任務(wù)完成，然后返回輸出對(duì)象。 還有一個(gè)重載方法也只能等待指定的時(shí)間，我們將它用于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沒(méi)有任何好處，但是當(dāng)我們想要重寫(xiě)某些Future接口方法并且不想實(shí)現(xiàn)Future接口的每個(gè)方法時(shí)，它就派上用場(chǎng)了。

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

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

總結(jié)

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

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