如何在Java中使用CompletableFuture处理异步流程_技术教程

CompletableFuture是Java中用于异步编程的核心工具，实现Future与CompletionStage接口，支持链式调用、任务组合及异常处理。通过supplyAsync和runAsync可创建有返回值或无返回值的异步任务，默认使用ForkJoinPool.commonPool()，也可指定自定义线程池。thenApply、thenAccept、thenRun实现结果转换与消费，thenCombine、thenCompose用于合并或串行依赖任务，allOf和anyOf协调多个任务的执行。异常处理通过exceptionally或handle方法完成，避免阻塞操作如get()，推荐回调方式提升I/O密集型场景下的性能与响应性。

在Java中，CompletableFuture 是处理异步编程的强大工具。它实现了 Future 和 CompletionStage 接口，支持链式调用、组合多个异步任务、异常处理以及回调机制，让非阻塞代码更清晰易读。

创建异步任务

你可以使用 runAsync 或 supplyAsync 启动一个异步操作：

runAsync：执行无返回值的任务，适合 void 类型的操作。
supplyAsync：执行有返回值的任务，返回 CompletableFuture。

默认情况下，这些方法使用 ForkJoinPool.commonPool() 线程池，但也可以传入自定义线程池以更好控制资源。

示例：

CompletableFuture future = CompletableFuture.runAsync(() -> {
    System.out.println("任务正在执行...");
});

CompletableFuture supplyFuture = CompletableFuture.supplyAsync(() -> {
    return "结果已生成";
});

链式调用与结果转换

通过 thenApply、thenAccept 和 thenRun 可以对前一个任务的结果进行后续处理：

thenApply(Function)：接收上一步结果并返回新值，可用于数据转换。
thenAccept(Consumer)：消费结果，不返回值，适合打印或存储。
thenRun(Runnable)：不关心结果，只在前任务完成后执行动作。

示例：

CompletableFuture result = CompletableFuture
    .supplyAsync(() -> "Hello")
    .thenApply(s -> s + " World")
    .thenApply(String::toUpperCase);

result.thenAccept(System.out::println); // 输出: HELLO WORLD

组合多个异步任务

当需要并行执行多个任务并合并结果时，可以使用以下方法：

thenCombine：合并两个独立的 CompletableFuture 的结果。
thenCompose：将一个 CompletableFuture 的输出作为另一个的输入（扁平化嵌套）。
allOf：等待所有 CompletableFuture 完成，适用于并行无依赖任务。
anyOf：任一任务完成即触发后续操作。

示例：合并两个远程请求结果

CompletableFuture f1 = CompletableFuture.supplyAsync(() -> fetchUser());
CompletableFuture f2 = CompletableFuture.supplyAsync(() -> fetchOrder());

CompletableFuture combined = f1.thenCombine(f2, (user, order) -> 
    "User: " + user + ", Order: " + order
);
combined.thenAccept(System.out::println);

异常处理

异步流程中的异常不会自动抛出，必须显式处理。常用方法包括：

exceptionally(Function)：捕获异常并提供默认值或降级逻辑。
handle(BiFunction)：无论是否异常都能处理，接收结果和异常两个参数。

示例：

CompletableFuture faulty = CompletableFuture
    .supplyAsync(() -> {
        throw new RuntimeException("网络错误");
    })
    .exceptionally(ex -> {
        System.err.println("发生异常: " + ex.getMessage());
        return "默认用户";
    });

faulty.thenAccept(System.out::println); // 输出: 默认用户

基本上就这些。合理使用 CompletableFuture 能显著提升程序响应性和吞吐量，尤其适合 I/O 密集型场景如 Web 请求、数据库查询等。关键是避免阻塞调用（如 get()），尽量用回调方式处理结果。