返利网站制作,大连开发区招聘信息最新招聘,外贸公司访问国外网站,四川华远建设工程有限公司网站有时我写了一篇有关Java Callable Future接口的文章#xff0c;我们可以使用它来获得线程的并发处理优势#xff0c;以及它们能够将值返回给调用程序。 FutureTask是Future接口的基础具体实现#xff0c;并提供异步处理。 它包含启动和取消任务的方法#xff0c;以及可以返… 有时我写了一篇有关Java Callable Future接口的文章我们可以使用它来获得线程的并发处理优势以及它们能够将值返回给调用程序。 FutureTask是Future接口的基础具体实现并提供异步处理。 它包含启动和取消任务的方法以及可以返回FutureTask状态完成还是取消的方法。 我们需要一个可调用的对象来创建未来的任务然后我们可以使用Java线程池执行器来异步处理这些任务。 让我们看一个带有简单程序的FutureTask示例。 由于FutureTask需要可调用对象因此我们将创建一个简单的Callable实现。 package com.journaldev.threads;import java.util.concurrent.Callable;public class MyCallable implements CallableString {private long waitTime;public MyCallable(int timeInMillis){this.waitTimetimeInMillis;}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);FutureTaskString futureTask1 new FutureTaskString(callable1);FutureTaskString futureTask2 new FutureTaskString(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 outputfutureTask1.get());}System.out.println(Waiting for FutureTask2 to complete);String s futureTask2.get(200L, TimeUnit.MILLISECONDS);if(s !null){System.out.println(FutureTask2 outputs);}} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}catch(TimeoutException e){//do nothing}}}} 当我们在上面的程序上运行时您会注意到它一段时间不打印任何内容因为FutureTask的get()方法等待任务完成然后返回输出对象。 还有一个重载方法也只能等待指定的时间我们将它用于futureTask2。 还要注意使用isDone()方法可确保在执行所有任务后终止程序。 上面程序的输出将是 FutureTask1 outputpool-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 outputpool-1-thread-2
Done 因此FutureTask没有任何好处但是当我们想要重写某些Future接口方法并且不想实现Future接口的每个方法时它就派上用场了。 参考 开发者食谱博客上来自我们JCG合作伙伴 Pankaj Kumar的Java FutureTask示例程序 。 翻译自: https://www.javacodegeeks.com/2013/07/java-futuretask-example-program.html
