Java 中 anyOf 怎么获取多个 CompletableFuture 中最快完成的结果-java教程-PHP中文网

completablefuture.anyof 返回 completablefuture，结果为首个完成 future 的原始值（object 类型），需手动类型转换并处理 completionexception 包装的异常；推荐使用自定义 race 方法实现类型安全的最快结果获取。

java 中 anyof 怎么获取多个 completablefuture 中最快完成的结果

Java 标准库中没有直接叫 anyOf 的方法来“获取最快完成结果的值”，但提供了 CompletableFuture.anyOf —— 它返回的是一个 CompletableFuture<object></object>，其结果是**任意一个入参 future 完成时的原始结果（Object 类型）**，不保证类型安全，也不自动传播异常（异常会包装为 CompletionException）。要真正“拿到最快完成的那个 future 的具体值（带类型）”，需要额外处理。

1. anyOf 返回的是 Object，必须手动强转和处理异常

CompletableFuture.anyOf(f1, f2, f3) 返回的 future 完成后，其结果是第一个完成的 future 的 get() 值（如果正常完成），但类型是 Object。你无法直接得到 String、Integer 等具体类型，且如果最快完成的是异常状态，它不会抛出原始异常，而是包装成 CompletionException。

Java Maven Code Review

审查Java Maven项目（ZIP压缩包或GitLab仓库URL），检查代码规范、命名、模块边界、可维护性问题以及重复代码。

下载

必须用 join() 或 get() 获取结果，再根据原始 future 的类型做向下转型（有风险）
推荐配合 handle() 或 whenComplete() 检查是否为异常完成
示例：

CompletableFuture<string> f1 = CompletableFuture.supplyAsync(() -> {
    sleep(200); return "result1";
});
CompletableFuture<integer> f2 = CompletableFuture.supplyAsync(() -> {
    sleep(100); return 42;
});

// 注意：anyOf 返回 CompletableFuture<object>
CompletableFuture<object> any = CompletableFuture.anyOf(f1, f2);
Object result = any.join(); // 得到 42（Integer）或 "result1"（String）
// 但你得自己判断 result 是什么类型，再转型
</object></object></integer></string>

2. 更安全的做法：统一泛型类型 + handle 提取结果

如果多个 future 都返回相同类型（比如都是 String），建议先用 thenApply 统一包装，再用 anyOf，最后用 handle 安全解包：

把每个 future 映射为 Optional<t></t> 或自定义结果容器（如 Result<t></t>），避免类型擦除问题
或全部转成 CompletableFuture<object></object> 后，在 handle 中检查 throwable 参数判断是否异常
示例（统一为 String）：

CompletableFuture<string> f1 = CompletableFuture.supplyAsync(() -> { sleep(300); return "A"; });
CompletableFuture<string> f2 = CompletableFuture.supplyAsync(() -> { sleep(150); return "B"; });

CompletableFuture<object> any = CompletableFuture.anyOf(f1, f2);
String fastest = (String) any.handle((result, ex) -> {
    if (ex != null) {
        // 处理异常情况，例如记录日志、抛自定义异常等
        throw new RuntimeException("All futures failed", ex);
    }
    return (String) result;
}).join();
</object></string></string>

3. 推荐替代方案：使用 allOf + 自定义 race 逻辑（类型安全）

若追求类型安全、可读性和可控性，不建议依赖 anyOf。更清晰的方式是：用 CompletableFuture.allOf 等待全部完成，同时用原子变量记录首个结果（race 风格）：

创建一个 AtomicReference<t></t> 和 CountDownLatch（或 AtomicBoolean）标记是否已录取
对每个 future 调用 whenComplete，首次成功就设置结果并结束
返回一个新的 CompletableFuture<t></t>，由你完全控制完成时机和异常传播

public static <t> CompletableFuture<t> race(CompletableFuture<t>... futures) {
    CompletableFuture<t> result = new CompletableFuture();
    AtomicBoolean done = new AtomicBoolean(false);
    
    for (CompletableFuture<t> f : futures) {
        f.whenComplete((val, ex) -> {
            if (done.compareAndSet(false, true)) {
                if (ex != null) {
                    result.completeExceptionally(ex);
                } else {
                    result.complete(val);
                }
            }
        });
    }
    return result;
}

// 使用
CompletableFuture<string> winner = race(f1, f2);
String s = winner.join(); // 类型安全，异常原样抛出
</string></t></t></t></t></t>