在 completionstage 的链式调用中，可以直接将函数式接口（如 function、consumer）作为参数传递给 thenapply、thenaccept 等方法。这些方法会自动接收上游阶段的结果并执行对应的逻辑，最终通过 tocompletablefuture() 获取可组合的 completablefuture 实例。
thenApply 如何转换数据流
thenApply 接收一个 Function<t r></t> 函数式接口，用于对上游结果进行转换并返回新值。它适用于需要修改或提取数据的场景，例如从异步任务返回的对象中提取关键字段。
import java.util.concurrent.CompletableFuture;
import java.util.function.Function;
public class Main {
public static void main(String[] args) {
CompletableFuture<String> stage = CompletableFuture.supplyAsync(() -> "Hello World");
// 使用 Function 转换数据
Function<String, String> transformer = s -> s.toUpperCase();
CompletableFuture<String> result = stage.thenApply(transformer).toCompletableFuture();
System.out.println(result.join());
}
}
thenAccept 如何处理副作用
thenAccept 接收一个 Consumer<t></t> 函数式接口，用于消费上游结果但不返回任何值。它适用于日志记录、数据库写入等不需要返回值但会产生副作用的操作。
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.CompletableFuture;
import java.util.function.Consumer;
public class Main {
public static void main(String[] args) {
CompletableFuture<Integer> stage = CompletableFuture.supplyAsync(() -> 42);
// 使用 Consumer 处理副作用
Consumer<Integer> handler = n -> System.out.println("Result: " + n);
stage.thenAccept(handler).toCompletableFuture();
}
}空值输入对函数式接口的影响
当上游阶段返回 null 时，传递给 thenApply 或 thenAccept 的函数式接口会接收到 null 值。如果函数内部未做空值检查，直接调用对象方法会导致 NullPointerException。因此，在使用函数式接口前需确保上游结果的合法性或在 lambda 表达式中加入防御性判断。
