Callable与Runnable
Java中的多线程实现可以通过继承Thread
或者实现Runnable
接口来实现,但是这两种方法都不能将执行结果取回。Runnable
接口定义如下:
1 | public interface Runnable { |
由于run()
方法返回值为void类型,所以在执行完任务之后无法返回任何结果。
Callable
位于java.util.concurrent包下,它也是一个泛型接口,在它里面也只声明了一个方法call()
,返回的类型就是传递进来的V
类型:
1 | public interface Callable<V> { |
Callable
一般情况下是配合ExecutorService
来使用的,在ExecutorService
接口中声明了若干个submit
方法的重载版本:
1 | <T> Future<T> submit(Callable<T> task); |
这三个方法中,常用的是第一个和第三个。
Future
Future
是一个接口,位于java.util.concurrent
包下,定义如下
1 | public interface Future<V> { |
Future
就是对于具体的Runnable
或者Callable
任务的执行结果进行取消、查询是否完成、获取结果。必要时可以通过get
方法获取执行结果,此方法会阻塞直到任务返回结果。上述方法中:
1 cancel
方法用来取消任务,如果取消任务成功则返回true,如果取消任务失败则返回false。参数mayInterruptIfRunning
表示是否允许取消正在执行却没有执行完毕的任务,如果设置true,则表示可以取消正在执行过程中的任务。如果任务已经完成,则无论mayInterruptIfRunning
为true还是false,此方法肯定返回false,即如果取消已经完成的任务会返回false;如果任务正在执行,若mayInterruptIfRunning
设置为true,则返回true,若mayInterruptIfRunning
设置为false,则返回false;如果任务还没有执行,则无论mayInterruptIfRunning
为true还是false,肯定返回true
2 isCancelled
方法表示任务是否被取消成功,如果在任务正常完成前被取消成功,则返回 true
3 isDone
方法表示任务是否已经完成,若任务完成,则返回true
4 get()
方法用来获取执行结果,这个方法会产生阻塞,会一直等到任务执行完毕才返回
5 get(long timeout, TimeUnit unit)
用来获取执行结果,如果在指定时间内,还没获取到结果,就直接返回null
FutureTask
由于Future
是个接口,所以其不能实例化,FutureTask
应运而生,也是Future
接口的唯一实现类。
FutureTask类实现了RunnableFuture接口
1 | public class FutureTask<V> implements RunnableFuture<V> {} |
RunnableFuture
继承了Runnable
接口和Future
接口,而FutureTask
实现了RunnableFuture
接口,关系如图所示。所以它既可以作为Runnable
被线程执行,又可以作为Future
得到Callable
的返回值。
FutureTask提供了2个构造器
1 | public FutureTask(Callable<V> callable) { |
使用方法
使用Callable + Future
获取执行结果
1 | ExecutorService executor = Executors.newCachedThreadPool(); |
使用Callable + FutureTask
获取执行结果
1 | ExecutorService executor = Executors.newCachedThreadPool(); |