使用Future

在执行多个任务的时候，使用Java标准库提供的线程池是非常方便的。我们提交的任务只需要实现Runnable接口，就可以让线程池去执行：

  1. class Task implements Runnable {
  2.     public String result;
  4.     public void run() {
  5.         this.result = longTimeCalculation(); 
  6.     }
  7. }

Runnable接口有个问题，它的方法没有返回值。如果任务需要一个返回结果，那么只能保存到变量，还要提供额外的方法读取，非常不便。所以，Java标准库还提供了一个Callable接口，和Runnable接口比，它多了一个返回值：

  1. class Task implements Callable<String> {
  2.     public String call() throws Exception {
  3.         return longTimeCalculation(); 
  4.     }
  5. }

并且Callable接口是一个泛型接口，可以返回指定类型的结果。

现在的问题是，如何获得异步执行的结果？

如果仔细看ExecutorService.submit()方法，可以看到，它返回了一个Future类型，一个Future类型的实例代表一个未来能获取结果的对象：

  1. ExecutorService executor = Executors.newFixedThreadPool(4); 
  2. // 定义任务:
  3. Callable<String> task = new Task();
  4. // 提交任务并获得Future:
  5. Future<String> future = executor.submit(task);
  6. // 从Future获取异步执行返回的结果:
  7. String result = future.get(); // 可能阻塞

当我们提交一个Callable任务后，我们会同时获得一个Future对象，然后，我们在主线程某个时刻调用Future对象的get()方法，就可以获得异步执行的结果。在调用get()时，如果异步任务已经完成，我们就直接获得结果。如果异步任务还没有完成，那么get()会阻塞，直到任务完成后才返回结果。

一个Future<V>接口表示一个未来可能会返回的结果，它定义的方法有：

  • get()：获取结果（可能会等待）
  • get(long timeout, TimeUnit unit)：获取结果，但只等待指定的时间；
  • cancel(boolean mayInterruptIfRunning)：取消当前任务；
  • isDone()：判断任务是否已完成。

练习

从使用Future - 图1下载练习：使用Future （推荐使用IDE练习插件快速下载）

小结

对线程池提交一个Callable任务，可以获得一个Future对象；

可以用Future在将来某个时刻获取结果。

读后有收获可以支付宝请作者喝咖啡：

使用Future - 图2