本文介绍在 java 中如何高效等待多个异步任务（completablefuture 列表）中第一个返回非 null 值的结果，一旦命中即立即终止其余任务等待，避免资源浪费。
本文介绍在 java 中如何高效等待多个异步任务（completablefuture 列表）中第一个返回非 null 值的结果，一旦命中即立即终止其余任务等待，避免资源浪费。
在并发编程中，常需从一组并行执行的异步操作中“择优选取”首个有效结果——例如调用多个服务端点获取用户信息，只要任一成功返回非空数据即可停止等待。Java 的 CompletableFuture 本身不提供原生的「首个非空完成」语义，但可通过组合与回调机制优雅实现。
核心思路是：创建一个辅助的 CompletableFuture<T>（如 firstNonNull），为原始列表中的每个 CompletableFuture 注册 whenComplete 回调；一旦某个 future 完成且其值非 null，立即调用 firstNonNull.complete(value) 终止整体等待流程。由于 CompletableFuture.complete() 是幂等且线程安全的，即使多个 future 同时完成，也仅首个非 null 值会生效，后续调用被忽略。
以下为完整示例代码：
import java.util.List;
import java.util.concurrent.CompletableFuture;
public class FirstNonNullWaiter {
public static <T> CompletableFuture<T> firstNonNull(List<CompletableFuture<T>> futures) {
CompletableFuture<T> firstNonNull = new CompletableFuture<>();
futures.forEach(future -> future.whenComplete((value, throwable) -> {
// 注意：仅当 value 非 null 且无异常时才采纳
if (value != null && throwable == null) {
firstNonNull.complete(value);
}
// 若 future 以异常结束或返回 null，不作任何操作，继续等待其他 future
}));
return firstNonNull;
}
// 使用示例
public static void main(String[] args) throws Exception {
List<CompletableFuture<String>> futures = List.of(
CompletableFuture.supplyAsync(() -> {
try { Thread.sleep(300); } catch (InterruptedException e) {}
return "result-from-A";
}),
CompletableFuture.supplyAsync(() -> {
try { Thread.sleep(100); } catch (InterruptedException e) {}
return null; // 模拟空结果
}),
CompletableFuture.supplyAsync(() -> {
try { Thread.sleep(200); } catch (InterruptedException e) {}
return "result-from-C";
})
);
String result = firstNonNull(futures).join(); // 阻塞等待首个非 null 结果
System.out.println("First non-null result: " + result); // 输出：result-from-C（因B返回null，C比A快）
}
}⚠️ 注意事项：
- whenComplete 不会中断底层任务执行（即其他 future 仍会继续运行），如需真正取消未完成的任务，应在 firstNonNull.complete() 后手动调用 future.cancel(true)（前提是 future 支持中断）；
- 若所有 future 均返回 null 或抛出异常，firstNonNull 将永久挂起——生产环境应配合超时控制，例如使用 firstNonNull.orTimeout(5, TimeUnit.SECONDS) 或 completeOnTimeout(null, 5, TimeUnit.SECONDS) 提供兜底行为；
- 该方案适用于 null 具有明确业务含义（如“无数据”）的场景；若需更复杂的成功判定逻辑（如非空字符串、正数等），可将判断条件封装为谓词函数（Predicate<T>）传入。
总结：通过一个共享的 CompletableFuture 协调多个异步源的完成信号，我们以声明式、低开销的方式实现了「首胜即止」语义，兼顾简洁性与工程健壮性。
