Callable&Future 接口
1. Callable接口
一种是通过创建Thread类,另一种是通过使用Runnable创建线程。但是Runnable缺少的一项功能是,当线程终止时(即run()完成时),我们无法使线程返回结果。为了支持此功能,Java中提供了Callable接口。
Callable 接口的特点如下:
- Callable,需要实现在完成时返回结果的
call()
方法。 call()
方法可以引发异常,而run()
则不能。- 为实现Callable而必须重写call方法。
- 不能直接替换Runnable,因为Thread类的构造方法根本没有Callable。
Thread的构造函数中只能接收Runable接口的类参数, 如何创建Thread?可以使用FutureTask构造函数传入Callable接口,FutureTask本身为Runable的实现类:
2. Future接口
当call()方法完成时,结果必须存储在主线程已知的对象中,以便主线程可以知道该线程返回的结果。为此可以使用Future对象。将Future视为保存结果的对象–-它可能暂时不保存结果,但将来会保存(一旦Callable返回)。Future基本上是主线程可以跟踪进度以及其他线程的结果的一种方式。这里列出了Future重要的方法,如下:
get():用于获取任务的结果。如果任务完成,它将立即返回结果,否则将等待任务完成,然后返回结果。
isDone():如果任务完成,则返回true,否则返回false。
cancel(boolean mayInterrupt):用于停止任务。如果尚未启动,它将停止任务。如果已启动,则仅在mayInterrupt为true时才会中断任务。
提示
可以看到Callable和Future做两件事--Callable与Runnable类似,因为它封装了要运行的任务,而Future用于存储从另一个线程获得的结果。实际上future也可以与Runnable一起使用。
3. 使用FutureTask
该类型实现了Runnable接口和Future接口,并方便地将两种功能组合在一起。可以通过为其构造函数提供Callable来创建FutureTask。然后将FutureTask对象提供给Thread的构造函数以创建Thread对象。因此间接地使用Callable创建线程。
3.1 核心要点
- 在主线程中需要执行比较耗时的操作时,但又不想阻塞主线程时,可以把这些作业交给Future对象在后台完成。
- 当主线程将来需要时,就可以通过 Future 对象获得后台作业的计算结果或者执行状态
- 一般FutureTask多用于耗时的计算,主线程可以在完成自己的任务后,再去获取结果。
- 仅在计算完成时才能检索结果;如果计算尚未完成,则阻塞get方法
- 一旦计算完成,就不能再重新开始或取消计算
- get方法而获取结果只有在计算完成时获取,否则会一直阻塞直到任务转入完成状态,然后会返回结果或者抛出异常
- get只计算一次,因此get方法放到最后
java
public static void main(String[] args) throws ExecutionException, InterruptedException {
// 创建未来任务
FutureTask<Integer> futureTask = new FutureTask<>(() -> {
System.out.println("开始执行。。。。。");
return 1024;
});
new Thread(futureTask, "futureTask").start();
// 轮询
while (!futureTask.isDone()){
System.out.println("---------wait---------");
}
// 结果汇总
Integer result = futureTask.get();
System.out.println(result);
}
运行结果:
3.2 总结
- 在主线程中需要执行比较耗时的操作时,但又不想阻塞主线程时,可以把这些作业交给Future对象在后台完成, 当主线程将来需要时,就可以通过Future对象获得后台作业的计算结果或者执行状态一般FutureTask多用于耗时的计算,主线程可以在完成自己的任务后,再去获取结果。
- 仅在计算完成时才能检索结果;如果计算尚未完成,则阻塞get方法。一旦计算完成,就不能再重新开始或取消计算。get方法而获取结果只有在计算完成时获取,否则会一直阻塞直到任务转入完成状态,然后会返回结果或者抛出异常。
- 只计算一次。