前面介绍 ExecutorService 线程池接口的时候,其中,提交任务的方法 submit() 的返回值就是Future接口类型的。
我们刚刚在学习java内置线程池使用时,没有考虑线程计算的结果,但开发中,我们有时需要利用线程进行一些计算,然后获取这些计算的结果,而java中的Future接口就是专门用于描述异步计算结果的,我们可以通过Future 对象获取线程计算的结果。
Future 的常用方法如下:
(1)boolean cancel(boolean mayInterruptIfRunning) —— 试图取消对此任务的执行
(2)V get() —— 如有必要,等待计算完成,然后获取其结果(用的比较多)
(3)V get(long timeout, TimeUnit unit) —— 如有必要,最多等待为使计算完成所给定的时间之后,获取其结果(如果结果可用)
(4)boolean isCancelled() —— 如果在任务正常完成前将其取消,则返回 true
(5)boolean isDone() —— 如果任务已完成,则返回 true
代码示例:
package com.zhoulz.demo04;
import javax.lang.model.element.VariableElement;
import java.util.concurrent.*;
/**
* 练习异步计算结果
*/
public class FutureDemo {
public static void main(String[] args) throws ExecutionException, InterruptedException, TimeoutException {
// 1、获取线程池对象
ExecutorService es = Executors.newCachedThreadPool();
// 2、创建Callable类型的任务(/线程)对象
// (另外单独创建一个类或者通过匿名内部类的方式都可以)
// (为什么不用Runnable类型的?因为其run()方法没有返回结果,所以一般不用)
// 任务创建好了之后(见下面),就可以提交任务了:
Future<Integer> f = es.submit(new MyCall(10, 20));
// 得到结果f后,就可以验证里面的方法了
//test1(f); // 把验证的一系列方法抽取成一个方法,见下面的test1()方法
// 取消任务的方法 - cancel()方法
//boolean cancel = f.cancel(true);
//System.out.println("取消任务的结果是:" + cancel);
// 等待给定的时间,获取结果 - V get(long timeout, TimeUnit unit)
Integer integer = f.get(1, TimeUnit.SECONDS);
System.out.println("任务执行的结果是:" + integer); // 由于等待时间过短,任务来不及执行,会报异常。
}
// 正常测试流程
private static void test1(Future<Integer> f) throws InterruptedException, ExecutionException {
// 3、判断线程/任务是否已经完成
boolean done = f.isDone();
System.out.println("第一次判断任务是否完成:" + done);
// 4、判断任务是否已经取消
boolean cancelled = f.isCancelled();
System.out.println("第一次判断任务是否取消:" + cancelled);
// 5、获取任务执行的结果
Integer integer = f.get(); //一直等待任务的执行,直到完成为止
System.out.println("任务执行的结果是:" + integer);
// 再次判断任务是否已经完成
boolean done2 = f.isDone();
System.out.println("第二次判断任务是否完成:" + done2);
// 再次判断任务是否已经取消
boolean cancelled2 = f.isCancelled();
System.out.println("第二次判断任务是否取消:" + cancelled2);
}
}
class MyCall implements Callable<Integer>{
private int a;
private int b;
// 通过构造方法传递两个参数
public MyCall(int a, int b) {
this.a = a;
this.b = b;
}
// 可见,待重写的call()方法是不带参数的,所以需要的参数只能通过构造方法来传递
@Override
public Integer call() throws Exception {
//return null;
String name = Thread.currentThread().getName();
System.out.println(name + "准备开始计算。。。");
Thread.sleep(2000); // 模拟线程执行时间:2秒
System.out.println(name + "计算完成。。。");
return a+b;
}
}