6.Callable&Future接口

6.1 Callable 接口

有两种创建线程的方法-一种是通过创建 Thread 类,另一种是通过使用 Runnable 创建线程。但是,Runnable 缺少的一项功能是,当线程终止时(即 run()完成时),我们无法使线程返回结果。为了支持此功能,Java 中提供了 Callable 接口。

==现在我们学习的是创建线程的第三种方案—Callable 接口==

Callable 接口的特点如下(重点)

  • 为了实现Runnable,需要实现不反悔任何内容的run( )方法,而对于Callable,需要实现在完成时返回结果的call( )方法。
  • call( )方法可以引发异常,而run( )则不能。
  • 为实现Callable而必须实现call方法
  • 不能直接替换runnable,因为Thread类的构造方法根本没有Callable
1
2
3
4
5
6
7
8
9
10
11
创建新类 MyThread 实现 runnable 接口
class MyThread implements Runnable{
@Override
public void run() {}
}
新类 MyThread2 实现 callable 接口
class MyThread2 implements Callable<Integer>{
@Override
public Integer call() throws Exception {
return 200; }
}

6.2 Future接口

当call( )方法完成时,结果必须存储在主线程已知的对象中,以便主线程可以知道该线程返回的结果。为此,可以使用Future对象。将Future视为保存结果的对象-它可能暂时不保存结果,当将来会保存(一旦Callable返回)。Future基本上是主线程可以跟踪进度以及其它线程的结果的一种方式。要实现此接口,必须重写5种方法,这里列出了重要的方法,如下:

  • public boolean cancel(boolean mayInterruptIfRunning) :用于停止任务。

    ==如果任务尚未启动,它将停止任务。如果已启动,则仅在mayInterrupt为true时才会中断任务。==

  • public Object get() 抛出InterruptedException, ExecutionException用于获取任务的结果。

    ==如果任务完成,它将立即返回结果,否则将等待任务完成,然后返回结果。==

  • public boolean isDone() :如果任务完成,则返回true,否则返回false

    可以看到Callable和Future做两件事- Callable与Runnable类似,因为它封装了要在另一个线程上运行的任务,而Future用于存储从另一个线程获得的结果。实际上,future也可以与Runnable一起使用。

    要创建线程,需要Runnable。为了获取结果,需要future。

6.3 FutureTask

Java 库具有具体的 FutureTask 类型,该类型实现 Runnable 和 Future,并方便地将两种功能组合在一起。 可以通过为其构造函数提供 Callable 来创建FutureTask。然后,将 FutureTask 对象提供给 Thread 的构造函数以创建Thread 对象。因此,间接地使用 Callable 创建线程。

核心原理:(重点)

在主线程中需要执行比较耗时的操作时,但又不想阻塞主线程时,可以把这些作业交给Future对象在后台完成

  • 当主线程将来需要时,就可以通过Future对象获得后台作业的计算结果或者执行状态
  • 一般FutureTask多用于耗时的计算,主线程可以在完成自己的任务后,再去获取结果。
  • 仅在计算完成时才能检索结果;如果计算尚未完成,则阻塞get方法
  • 一旦计算完成,就不能再重新开始或取消计算
  • get方法而获取结果只有在计算完成时获取,否则会一直阻塞知道任务转入完成状态,然后会返回结果或者抛出异常
  • get只计算一次,因此get方法放到最后

6.4 使用Callable和Future

6.5 小结(重点)

  • 在主线程中需要执行比较耗时的操作时,但有不想阻塞主线程时,可以把这些作业交给Future对象在后台完成。当主线程将来需要时,就可以通过Future对象获得后台作业的计算结果或者执行状态
  • 一般FutureTask多用于耗时的计算,主线程可以在完成自己的任务后,再去获取结果
  • 仅在计算完成时才能检索结果;如果计算尚未完成,则阻塞get方法。一旦计算完成,就不能再重新开始或取消计算。get方法而获取结果只有在计算完成时获取,否则会一直折射知道任务转入完成状态,然后会返回结果或者抛出异常。
  • 只计算一次结果