Java FutureTask示例程序
时间:2020-02-23 14:36:36 来源:igfitidea点击:
FutureTask是Future接口的基础具体实现,并提供异步处理。
它包含启动和取消任务的方法,以及可以返回FutureTask状态(完成还是取消)的方法。
我们需要一个可调用的对象来创建将来的任务,然后我们可以使用Java线程池执行器来异步处理这些任务。
让我们看一个带有简单程序的FutureTask示例。
由于FutureTask需要可调用对象,因此我们将创建一个简单的Callable实现。
package com.theitroad.threads; import java.util.concurrent.Callable; public class MyCallable implements Callable<String> { private long waitTime; public MyCallable(int timeInMillis){ this.waitTime=timeInMillis; } @Override public String call() throws Exception { Thread.sleep(waitTime); //return the thread name executing this callable task return Thread.currentThread().getName(); } }
这是FutureTask方法的示例,它显示了FutureTask的常用方法。
package com.theitroad.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 service executor.shutdown(); return; } if(!futureTask1.isDone()){ //wait indefinitely for future task to complete System.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接口的每种方法时,它就派上用场了。