CompletableFuture的allOf等待所有任务完成,anyOf在任一任务完成后即响应;allOf返回Void需手动获取各结果,anyOf返回Object需类型转换,二者均不自动处理异常,需结合exceptionally或handle方法管理错误,适用于并行任务协调与快速响应场景。

在Java中,CompletableFuture 是处理异步编程的重要工具。当我们需要同时处理多个异步任务时,allOf 和 anyOf 方法能帮助我们更方便地协调这些任务的执行和结果获取。
CompletableFuture.allOf:等待所有任务完成
allOf 用于等待一组 CompletableFuture 全部完成。它返回一个 CompletableFuture<Void>,当所有传入的任务都执行完毕后,这个返回的 future 才会完成。
注意:allOf 不会合并结果,你需要手动获取每个 future 的结果。
使用场景示例:
立即学习“Java免费学习笔记(深入)”;
- 发起多个远程API调用,等全部返回后再处理聚合数据
- 并行执行多个独立任务,确保它们都完成后才继续
代码示例:
CompletableFuture<String> task1 = CompletableFuture.supplyAsync(() -> {
// 模拟耗时操作
sleep(1000);
return "Result1";
});
CompletableFuture<String> task2 = CompletableFuture.supplyAsync(() -> {
sleep(800);
return "Result2";
});
CompletableFuture<String> task3 = CompletableFuture.supplyAsync(() -> {
sleep(1200);
return "Result3";
});
// 等待所有任务完成
CompletableFuture<Void> allDone = CompletableFuture.allOf(task1, task2, task3);
// 在所有任务完成后处理结果
allDone.thenRun(() -> {
try {
String r1 = task1.get(); // 获取结果
String r2 = task2.get();
String r3 = task3.get();
System.out.println("All results: " + r1 + ", " + r2 + ", " + r3);
} catch (Exception e) {
throw new RuntimeException(e);
}
});
如果其中一个任务失败,allOf 返回的 future 也会失败。你可以通过 whenComplete 或 handle 来处理异常情况。
CompletableFuture.anyOf:任一任务完成即响应
anyOf 用于监听多个 CompletableFuture,只要其中任意一个完成(无论是正常完成还是异常完成),返回的 future 就会完成。
它返回的是 CompletableFuture<Object>,因为无法保证是哪个任务先完成,类型只能是 Object,需要手动转型。
使用场景示例:
立即学习“Java免费学习笔记(深入)”;
- 从多个数据源查询同一数据,取最快返回的结果
- 提供备用服务调用,主服务超时前若备选完成可提前响应
代码示例:
CompletableFuture<String> fastTask = CompletableFuture.supplyAsync(() -> {
sleep(500);
return "Fast result";
});
CompletableFuture<String> slowTask = CompletableFuture.supplyAsync(() -> {
sleep(2000);
return "Slow result";
});
CompletableFuture<Object> anyDone = CompletableFuture.anyOf(fastTask, slowTask);
anyDone.thenAccept(result -> {
System.out.println("First done: " + result); // 输出: Fast result
});
注意:anyOf 不关心其他未完成的任务,即使有任务后续抛出异常也不会影响已触发的回调。如果你需要处理异常,建议在原始 future 上使用 exceptionally 或 handle。
常见问题与注意事项
使用 allOf 和 anyOf 时需要注意以下几点:
- allOf 返回的 future 只有在所有任务都完成时才完成,哪怕某个任务失败也会导致整体失败
- anyOf 返回的 future 一旦任一任务完成就完成,其余任务不会被取消,可能继续执行
- anyOf 的结果是 Object 类型,必须小心类型转换
- 如果想在 anyOf 中忽略异常任务,可以在每个 future 上先用 exceptionally 处理
- 不要忘记对 allOf 的结果调用 join() 或 get() 否则可能主线程提前退出
基本上就这些。合理使用 allOf 和 anyOf 能让异步流程控制变得更清晰高效。关键是理解它们的行为差异:allOf 强调“全部”,anyOf 关注“首个”。









