Java Future
Java Future,即java.util.concurrent.Future,表示异步计算的结果。创建异步任务后,将返回JavaFuture
对象。这个" Future"对象用作异步任务结果的句柄。一旦异步任务完成,就可以通过启动任务时返回的" Future"对象访问结果。
Java的一些内置并发实用程序,例如Java ExecutorService,从其某些方法中返回JavaFuture
对象。对于ExecutorService,当我们提交一个Callable使其并发(异步)执行时,它将返回一个Future。
Java Future接口定义
为了理解JavaFuture
接口的工作方式,这是接口定义的近似值:
public interface Future<V> { boolean cancel(boolean mayInterruptIfRunning) V get(); V get(long timeout, TimeUnit unit); boolean isCancelled(); boolean isDone(); }
这些方法的每一个都将在后面的部分中介绍,但是正如我们所看到的,Java的" Future"接口并不是那么高级。
从Future获得结果
如前所述,Java" Future"表示异步任务的结果。为了获得结果,我们可以在" Future"上调用两个" get()"方法之一。 get()方法都返回一个Object,但是返回类型也可以是一个通用的返回类型(意味着特定类的对象,而不仅仅是Object)。这是一个通过JavaFuture
的get()
方法获得结果的示例:
Future future = ... // get Future by starting async task // do something else, until ready to check result via Future // get result from Future try { Object result = future.get(); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); }
如果我们在异步任务完成之前调用get()方法,则get()方法将阻塞直到结果准备就绪。
有一个get()
方法的版本,它可以在经过一定时间后超时,我们可以通过方法参数来指定。这是一个调用get()
版本的示例:
try { Object result = future.get(1000, TimeUnit.MILLISECONDS); } catch (InterruptedException e) { } catch (ExecutionException e) { } catch (TimeoutException e) { // thrown if timeout time interval passes // before a result is available. }
上面的示例最多等待1000毫秒,以便结果在"未来"中可用。如果在1000毫秒内没有可用结果,则抛出" TimeoutException"。
通过将来的取消任务cancel()
我们可以通过调用Future
cancel()
方法来取消由JavaFuture
实例表示的异步任务。必须实现异步任务执行以支持取消。没有这种支持,调用cancel()
将无效。这是通过Java`Future``cancel()方法取消任务的示例:
future.cancel();
检查任务是否完成
我们可以通过调用Future
isDone()
方法来检查异步任务是否已完成(以及是否有可用的结果)。这是一个调用JavaFuture``isDone()
方法的示例:
Future future = ... // Get Future from somewhere if(future.isDone()) { Object result = future.get(); } else { // do something else }
检查任务是否已取消
也可以检查由JavaFuture
表示的异步任务是否被取消。我们可以通过调用Future
isCancelled()
方法进行检查。这是检查任务是否被取消的示例:
Future future = ... // get Future from somewhere if(future.isCancelled()) { } else { }