[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);
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

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

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