[AIGC] Java CompletableFuture：简介及示例

Java 8 引入了一个名为 CompletableFuture 的新库，正如其名称所示，该库提供了一种名为 “Completable Future” 的新 API，其主要目的是支持异步编程，并通过可搜索的操作将这些异步操作进行聚合管控。

---

CompletableFuture 简介

Java 中的 CompletableFuture 实现了 Future 和 CompletionStage 接口，是对 Future 的补充和增强。在原生的 Future 中，我们只能通过 get 方法来获取执行结果，但这种方式会阻塞当前线程，导致其等待任务执行完毕，无法进行接下来的操作。

然而，CompletableFuture 解决了这个问题，它提供了非阻塞的方式来处理计算结果。你可以将一系列的异步操作组合起来，比如当一个操作完成后，可以执行另一个操作，当所有操作完成后，还可以获得最终的结果。

CompletableFuture 示例

下面的例子演示了如何使用 CompletableFuture：

import java.util.concurrent.CompletableFuture;public class CompletableFutureExample {public static void main(String[] args) throws Exception {CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {// 模拟长时间的计算任务try {Thread.sleep(1000);} catch (InterruptedException e) {}// 返回结果return "42";});future.thenAccept(result -> {System.out.println("计算结果: " + result);});// 阻塞，等待异步任务执行完毕（在实际应用中应尽量避免这种阻塞）Thread.sleep(2000);}
}

在这个示例中，我们创建了一个 CompletableFuture 实例，该实例通过 supplyAsync 方法启动了一个异步任务。当这个任务完成后，我们使用 thenAccept 方法来处理计算结果。最后，我们使用 Thread.sleep 方法让主线程等待异步任务执行完毕。

希望这篇文章有助于你理解和使用 Java 的 CompletableFuture。异步编程是一个复杂且强大的工具，在理解了其基本概念后，你会发现它在处理复杂且耗时的计算任务时，能够大大提高你的代码的效率和响应性。