Java并发编程中CompletableFuture使用方法-java教程-PHP中文网

Java并发编程中CompletableFuture使用方法

P粉602998670

发布： 2025-10-02 17:24:02

原创

420人浏览过

CompletableFuture 提供非阻塞异步编程能力，支持链式调用组合任务。1. 用 runAsync/supplyAsync 创建异步任务，可指定线程池；2. thenApply/thenAccept/thenRun 实现结果处理；3. thenCompose 串行组合任务，thenCombine 并行合并结果；4. exceptionally/handle 进行异常处理；5. allOf/anyOf 协调多个任务同步。合理使用可提升代码可读性与健壮性，适用于 I/O 密集型场景。

java并发编程中completablefuture使用方法

在Java并发编程中，CompletableFuture 是对 Future 的增强，提供了非阻塞、函数式、可编排的异步编程能力。它允许你以链式调用的方式组合多个异步任务，避免回调地狱，提升代码可读性和维护性。

1. 创建 CompletableFuture 任务

你可以通过静态方法创建一个异步任务：

runAsync()：执行无返回值的任务
supplyAsync()：执行有返回值的任务

默认使用 ForkJoinPool.commonPool() 线程池，也可以传入自定义线程池：

CompletableFuture<Void> run = CompletableFuture.runAsync(() -> {
    System.out.println("执行无返回任务");
});
<p>CompletableFuture<String> supply = CompletableFuture.supplyAsync(() -> {
return "Hello from async";
}, Executors.newFixedThreadPool(2));</p>

登录后复制

2. 任务完成后处理结果（thenApply, thenAccept, thenRun）

当异步任务完成时，可以进行后续操作：

立即学习“Java免费学习笔记（深入）”；

豆包AI编程

豆包推出的AI编程助手

483

查看详情

thenApply(Function)：转换结果并返回新值
thenAccept(Consumer)：消费结果，无返回
thenRun(Runnable)：不关心结果，只运行后续逻辑

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hi");
<p>future.thenApply(s -> s + " World")
.thenAccept(System.out::println)
.thenRun(() -> System.out.println("完成"));</p>

登录后复制

3. 组合多个异步任务（thenCompose, thenCombine）

当你需要合并多个异步操作时，这两个方法非常有用：

thenCompose：串行组合，前一个任务的结果用于下一个任务（类似 flatMap）
thenCombine：并行组合，两个任务都完成后合并结果

// 串行：先获取用户，再获取订单
CompletableFuture<User> getUser = CompletableFuture.supplyAsync(() -> new User("Alice"));
CompletableFuture<Order> getOrder = getUser.thenCompose(user ->
    CompletableFuture.supplyAsync(() -> new Order(user.getName()))
);
<p>// 并行：同时获取价格和折扣，然后合并
CompletableFuture<Double> price = CompletableFuture.supplyAsync(() -> 100.0);
CompletableFuture<Double> discount = CompletableFuture.supplyAsync(() -> 0.9);
CompletableFuture<Double> finalPrice = price.thenCombine(discount, (p, d) -> p * d);</p>

登录后复制

4. 异常处理（handle, exceptionally）

异步任务可能出错，CompletableFuture 提供了异常处理机制：

exceptionally(Function)：仅处理异常，返回默认值
handle(BiFunction)：无论是否异常都会执行，可统一处理结果和异常

CompletableFuture<String> broken = CompletableFuture.supplyAsync(() -> {
    throw new RuntimeException("出错了");
});
<p>broken.exceptionally(ex -> "默认值")
.thenAccept(System.out::println);</p><p>// 或者用 handle
broken.handle((result, ex) -> {
if (ex != null) {
System.out.println("捕获异常: " + ex.getMessage());
return "恢复结果";
}
return result;
});</p>

登录后复制

5. 等待多个任务完成（allOf, anyOf）

当你需要协调多个异步任务时：

CompletableFuture.allOf(...)：所有任务都完成才算完成，返回 void
CompletableFuture.anyOf(...)：任意一个完成即完成

CompletableFuture<String> f1 = CompletableFuture.supplyAsync(() -> "A");
CompletableFuture<String> f2 = CompletableFuture.supplyAsync(() -> "B");
CompletableFuture<String> f3 = CompletableFuture.supplyAsync(() -> "C");
<p>CompletableFuture<Void> all = CompletableFuture.allOf(f1, f2, f3);
all.thenRun(() -> {
System.out.println("全部完成");
try {
System.out.println(f1.get()); // 获取结果
} catch (Exception e) { }
});</p>

登录后复制

基本上就这些核心用法。合理使用 CompletableFuture 能让你的异步代码更清晰、更健壮，尤其适合 I/O 密集型或远程调用场景。关键是理解每个方法的返回类型和执行时机，避免阻塞主线程。

以上就是Java并发编程中CompletableFuture使用方法的详细内容，更多请关注php中文网其它相关文章！