CompletableFuture.anyOf用于获取多个异步任务中首个完成的结果，返回CompletableFuture，需处理类型转换和异常。示例中serviceB先完成并输出结果，适用于多源数据获取等场景。
在Java中，当你需要同时执行多个异步任务，并只关心第一个完成的任务结果时，CompletableFuture.anyOf 是一个非常实用的工具。它允许你启动多个任务，一旦其中任意一个完成，就可以立即获取其结果，而无需等待其他任务结束。
理解 CompletableFuture.anyOf 的作用
CompletableFuture.anyOf 接收多个 CompletableFuture 实例作为参数，返回一个新的 CompletableFuture。这个返回的 future 会在任意一个输入 future 完成时立即完成。需要注意的是，anyOf 返回的是 CompletableFuture，因为无法保证哪个 future 先完成，所以结果类型是 Object，你需要根据实际任务进行类型判断和转换。
基本使用步骤
以下是使用 anyOf 处理竞争任务的典型流程：
- 创建多个异步任务（每个返回 CompletableFuture）
- 将这些 future 传入 CompletableFuture.anyOf()
对 anyOf 返回的 future 调用 join() 或 get() 获取最先完成的结果
- 对结果进行类型判断和处理
实际代码示例
假设我们有两个远程服务调用，希望谁先返回就用谁的结果：
import java.util.concurrent.CompletableFuture;
public class AnyOfExample {
public static void main(String[] args) {
// 模拟两个响应速度不同的服务
CompletableFuture serviceA = CompletableFuture.supplyAsync(() -> {
try { Thread.sleep(2000); } catch (InterruptedException e) {}
return "来自服务A的结果";
});
CompletableFuture serviceB = CompletableFuture.supplyAsync(() -> {
try { Thread.sleep(1000); } catch (InterruptedException e) {}
return "来自服务B的结果";
});
// 使用 anyOf 等待任意一个完成
CompletableFuture
处理结果类型与异常
由于 anyOf 返回 Object 类型，建议结合 instanceof 判断结果类型。同时要注意，即使某个任务因异常失败，anyOf 也可能以异常完成，因此可以添加异常处理：
fastest.whenComplete((result, ex) -> {
if (ex != null) {
System.out.println("最快的任务出错: " + ex.getMessage());
} else {
if (result instanceof String) {
System.out.println("成功结果: " + result);
}
}
});
基本上就这些。CompletableFuture.anyOf 特别适合用于超时降级、多源数据获取、服务冗余等场景，能有效提升系统响应速度。关键是记得处理类型转换和异常，避免运行时错误。
