Java Future 示例

2025年3月17日 | 阅读 14 分钟

在 Java 中，Future 是一个属于 java.util.concurrent 包的接口。它用于表示异步计算的结果。该接口提供了检查计算是否完成、等待其完成以及检索计算结果的方法。一旦任务或计算完成，就无法取消该计算。

语法

Java Future 示例

Java Future 的最佳示例是 ExecutorService 接口。它会从其某些方法生成 Future (来自其某些方法) 对象，用于跟踪一个或多个异步任务的进度。

Future 接口的方法

该接口提供了以下五种方法

方法	描述
cancel()	它尝试取消任务的执行。
get()	该方法在必要时等待计算完成，然后检索其结果。
get()	在必要时，最多等待给定的时间让计算完成，然后检索其结果（如果可用）。
isCancelled()	如果任务在完成之前被取消，则返回 true。
isDone()	如果任务已完成，则返回 true。

Future 接口存在一些不足之处，如下所示：

使用 Future，无法手动完成计算。
计算完成后，它不会通知。
无法创建和组合其链。

为了克服上述限制，Java 8 引入了 CompletableFuture。

在异步编程中使用 Future

获取结果

正如我们上面所讨论的，Future 表示异步任务的结果。为了检索该异步任务的结果，Java Future 接口提供了以下两个 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() 方法将阻塞直到结果准备就绪。

为了克服上述缺点，Future 接口提供了另一个 get() 方法版本，该版本接受一个 **时间**（以毫秒为单位）作为参数。它表示 Future 将等待一段时间来完成任务，之后结果将在 Future 中可用。例如：

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.
}

如果在指定时间内 Future 没有获得任何结果，Future 将抛出 **TimeoutException**。

取消异步任务

我们还可以通过调用 Future 接口的 cancel() 方法随时取消异步任务。例如：

Future future = ... // Get Future from somewhere
future.cancel();

检查异步任务是否完成

该接口提供了一个 isDone() 方法来检查异步任务是否完成。例如：

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

检查异步任务是否已取消

Future 接口提供了一个 isCancelled() 方法来检查由 Future 表示的异步任务是否已取消。如果任务成功取消，则返回 true，否则返回 false。例如：

Future future = ... // get Future from somewhere
if(future.isCancelled()) 
{
} 
else 
{
}