Java CompletableFuture.thenAccept与thenRun的返回值差异

在 Java 异步编程中，CompletableFuture 是处理并发任务的核心工具。理解 thenAccept 和 thenRun 的区别，对于精准控制任务执行流程和数据传递至关重要。以下指南将手把手带你拆解两者的核心差异。

1. 理解核心概念：有值消费 vs. 无值执行

这两个方法都用于在上一个任务完成后执行下一步操作，且都不返回新的计算结果（即返回值都是 CompletableFuture<Void>）。它们的关键区别在于是否需要感知上一个任务的结果。

• thenAccept：消费上一个任务的结果。如果你需要在后续步骤中使用前面计算出来的数据，必须用它。
• thenRun：不感知上一个任务的结果。如果你只想在任务结束后做些收尾工作（如打印日志、更新状态），不需要前面的数据，用它。

2. 使用 thenAccept 处理带值结果

当你需要读取并处理前一个阶段返回的数据时，请使用 thenAccept。它接受一个 Consumer 函数式接口。

编写如下代码，体验“接收值”的过程：

import java.util.concurrent.CompletableFuture;

public class ThenAcceptDemo {
    public static void main(String[] args) {
        // 步骤 1：创建一个 supplyAsync 任务，计算一个字符串
        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
            return "Hello World";
        });

        // 步骤 2：使用 thenAccept 接收结果
        // 注意：lambda 表达式的参数 s 就是上一步返回的 "Hello World"
        CompletableFuture<Void> resultFuture = future.thenAccept(s -> {
            // 在这里我们可以直接使用 s
            String processed = s.toUpperCase();
            System.out.println("处理后的结果: " + processed);
        });

        // 步骤 3：确认最终返回值类型
        System.out.println("最终返回类型是否为 Void: " + (resultFuture.get() == null));
    }
}

观察代码逻辑：

1. supplyAsync 返回了 String。
2. thenAccept 中的 s -> { ... } 捕获了这个 String。
3. 整个链式调用的最终返回值 resultFuture 的类型是 CompletableFuture<Void>，意味着你不能通过 resultFuture.get() 再拿到那个大写的字符串。数据流向在 thenAccept 内部终止了（变成了副作用）。

3. 使用 thenRun 忽略结果

如果你只关心任务“做完了”，而不关心它“产生了什么数据”，请使用 thenRun。它接受一个 Runnable 函数式接口，这意味着它的 run() 方法没有参数。

编写如下代码，体验“忽略值”的过程：

import java.util.concurrent.CompletableFuture;

public class ThenRunDemo {
    public static void main(String[] args) {
        // 步骤 1：创建一个 supplyAsync 任务
        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
            return "Hello World";
        });

        // 步骤 2：使用 thenRun
        // 注意：lambda 表达式 () -> { ... } 没有参数，无法获取 "Hello World"
        CompletableFuture<Void> resultFuture = future.thenRun(() -> {
            // 这里无法访问上面的 "Hello World"
            System.out.println("任务执行完毕，清理现场或发送通知");
        });

        // 步骤 3：阻塞等待以确保异步任务执行完毕（仅用于演示）
        resultFuture.join();
    }
}

观察代码逻辑：

1. supplyAsync 虽然返回了 String。
2. thenRun 中的 () -> { ... } 是无参的，编译器禁止你在括号里写参数来接收结果。
3. 它同样返回 CompletableFuture<Void>。

4. 返回值与参数的详细对比

为了更直观地展示两者的区别，请参考下表。请注意，虽然它们的“返回值类型”相同，但在“数据传递能力”上截然不同。

5. 决策流程：如何选择方法

在实际编码中，通过以下逻辑流程快速决定使用哪个方法。

解析：

• 如果你的代码逻辑依赖于前面的计算结果（例如：计算了订单总价 price，下一步需要 price > 100 来判断是否打折），必须走 thenAccept 分支。
• 如果你的代码逻辑仅仅是“触发生效”（例如：无论订单金额多少，发一条“下单成功”的短信），走 thenRun 分支。

6. 验证编译器的强制约束

为了巩固理解，尝试编写一段错误代码，强制让 thenRun 接收参数，看看编译器如何反应。

输入以下代码：

CompletableFuture.supplyAsync(() -> "Data")
    .thenRun(data -> { 
        // 故意错误：试图在 Runnable 中使用参数
        System.out.println(data); 
    });

观察编译器报错信息：
IDE 会提示类似 Target type of a lambda conversion must be an interface 或者直接在 data 下划红线。因为 Runnable 的 run() 方法定义是 void run()，它不支持参数。这从语法层面强制保证了 thenRun 的“无结果感知”特性。

将上述代码修改为 thenAccept：

CompletableFuture.supplyAsync(() -> "Data")
    .thenAccept(data -> { 
        // 修改正确：thenAccept 的 Consumer 允许参数
        System.out.println(data); 
    });

代码即可正常编译。