Java Future

时间:2020-01-09 10:36:27  来源:igfitidea点击:

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)。这是一个通过JavaFutureget()方法获得结果的示例:

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()

我们可以通过调用Futurecancel()方法来取消由JavaFuture实例表示的异步任务。必须实现异步任务执行以支持取消。没有这种支持,调用cancel()将无效。这是通过Java`Future``cancel()方法取消任务的示例:

future.cancel();

检查任务是否完成

我们可以通过调用FutureisDone()方法来检查异步任务是否已完成(以及是否有可用的结果)。这是一个调用JavaFuture``isDone()方法的示例:

Future future = ... // Get Future from somewhere

if(future.isDone()) {
    Object result = future.get();
} else {
    // do something else
}

检查任务是否已取消

也可以检查由JavaFuture表示的异步任务是否被取消。我们可以通过调用FutureisCancelled()方法进行检查。这是检查任务是否被取消的示例:

Future future = ... // get Future from somewhere

if(future.isCancelled()) {

} else {

}