在 java 中，completablefuture 的 thencombine 方法用于将两个独立的异步任务结果合并处理。你只需调用其中一个 future 实例的 thencombine 方法，传入另一个 future 作为参数，并指定一个接收两个结果的函数即可。该方法会等待两个任务都完成后执行回调，返回一个新的 completablefuture，其值为合并后的结果。
如何定义合并逻辑与返回值类型
thenCombine 的核心在于第三个参数：一个实现 BiFunction 接口的函数。这个函数接收前两个任务的返回值，并输出最终结果。例如，若第一个任务返回字符串，第二个任务返回整数，你可以将它们拼接或计算后返回一个新对象。注意，thenCombine 是同步执行的，即回调函数在当前线程运行，除非你显式使用异步版本。
import java.util.concurrent.CompletableFuture;
public class CombineExample {
public static void main(String[] args) throws Exception {
CompletableFuture<String> futureA = CompletableFuture.supplyAsync(() -> "Hello");
CompletableFuture<Integer> futureB = CompletableFuture.supplyAsync(() -> 42);
CompletableFuture<String> combined = futureA.thenCombine(futureB, (str, num) -> str + " " + num);
System.out.println(combined.get()); // 输出: Hello 42
}
}如何处理异常与默认值
如果参与合并的两个任务中任何一个抛出异常，thenCombine 生成的新 Future 也会直接携带该异常。你可以通过链式调用 exceptionally 或 handle 来捕获并处理这些异常，或者提供默认值。此外，thenCombine 不会自动跳过已完成的任务，它必须等待两个输入 Future 均完成。若需忽略某个任务的失败，可先在该任务上调用 exceptionally 返回默认值，再进入合并流程。
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.CompletableFuture;
public class CombineWithException {
public static void main(String[] args) throws Exception {
CompletableFuture<String> futureA = CompletableFuture.supplyAsync(() -> "Success");
CompletableFuture<Integer> futureB = CompletableFuture.supplyAsync(() -> { throw new RuntimeException("Fail"); });
// 为 futureB 提供默认值
CompletableFuture<Integer> safeFutureB = futureB.exceptionally(e -> 0);
CompletableFuture<String> combined = futureA.thenCombine(safeFutureB, (str, num) -> str + " -> " + num);
System.out.println(combined.get()); // 输出: Success -> 0
}
}基于 thenCombine 返回值的实际应用场景
在实际开发中，thenCombine 常用于聚合多个微服务或数据库查询的结果。例如，获取用户信息后，再并行获取其订单列表，最后合并成一个完整的用户视图对象。这种模式避免了串行等待，提升了响应速度。关键在于确保每个子任务独立且无副作用，合并函数纯粹基于输入计算输出。
