使用 CompletableFuture 实现“竞速执行”：并发提交多个异步任务，一旦任一任务返回满足条件的结果（如 "apple"），立即返回该结果并自动取消所有未完成任务。
使用 `completablefuture` 实现“竞速执行”：并发提交多个异步任务，一旦任一任务返回满足条件的结果（如 `"apple"`），立即返回该结果并自动取消所有未完成任务。
在 Java 并发编程中，ExecutorService.invokeAll() 会阻塞等待所有任务完成，无法满足“只要第一个成功结果即终止其余任务”的需求——正如示例代码所示，此时循环遍历 Future.get() 已属事后检查，其他任务早已执行完毕，失去取消意义。
更优解是采用 CompletableFuture 构建响应式竞速模型。其核心优势在于：非阻塞监听、细粒度完成回调、天然支持任务取消传播。以下为推荐实现：
✅ 推荐方案：anyMatch 辅助方法（精准匹配 + 自动取消）
import java.util.*;
import java.util.concurrent.*;
import java.util.function.Predicate;
import java.util.stream.Collectors;
public class FirstSuccessExecutor {
public static String getFirstMatchingResult(List<String> ids,
ExecutorService executor) throws Exception {
List<CompletableFuture<String>> futures = ids.stream()
.map(id -> CompletableFuture.supplyAsync(() -> hitEndpoint(id), executor))
.collect(Collectors.toList());
return anyMatch(futures, "apple"::equals).get(); // 阻塞直到首个匹配结果或异常
}
// 通用工具：等待首个满足 predicate 的 CompletionStage 完成
public static <T> CompletableFuture<T> anyMatch(
List<? extends CompletionStage<T>> stages,
Predicate<T> criteria) {
CompletableFuture<T> result = new CompletableFuture<>();
// 对每个 stage 注册 accept 回调：一旦值匹配，立即 complete 主结果
List<CompletableFuture<?>> listeners = stages.stream()
.map(stage -> stage.thenAccept(value -> {
if (criteria.test(value) && !result.isDone()) {
result.complete(value);
}
}))
.collect(Collectors.toList());
// 当所有监听器注册完毕后，确保：若无匹配则失败（避免永久挂起）
CompletableFuture.allOf(listeners.toArray(new CompletableFuture[0]))
.whenComplete((ignored, throwable) -> {
if (!result.isDone()) {
result.completeExceptionally(
throwable != null ? throwable : new NoSuchElementException("No match found")
);
}
});
return result;
}
// 模拟接口调用（含可能的延迟/失败）
private static String hitEndpoint(String id) {
try {
Thread.sleep(100 + (long)(Math.random() * 300)); // 模拟网络波动
return switch (id) {
case "1" -> "mangoes";
case "2" -> "oranges";
case "3" -> "apple"; // 目标结果
case "4" -> throw new RuntimeException("API timeout");
default -> "unknown";
};
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new RuntimeException(e);
}
}
}⚠️ 关键注意事项
-
取消传播需显式支持：
CompletableFuture默认不自动取消底层Future。若hitEndpoint()内部使用了可中断的 I/O（如HttpURLConnection.setConnectTimeout()或OkHttp的Call.cancel()），需在supplyAsync中手动捕获中断并触发取消逻辑；否则，已启动但未完成的任务将继续运行（仅主线程不再等待）。 -
避免字符串误用：示例中
st1 == "apple"应改为Objects.equals(st1, "apple")或"apple".equals(st1)，防止空指针与引用比较错误。 -
线程池管理：务必复用
ExecutorService（如Executors.newCachedThreadPool()），避免为每次调用创建新线程池；任务结束后，根据场景决定是否shutdown()。 -
超时防护：生产环境应添加超时控制，例如：
anyMatch(...).orTimeout(5, TimeUnit.SECONDS)，防止因全部失败或阻塞导致无限等待。
✅ 替代思路（轻量级，适用于简单场景）
若仅需首个非空/非异常结果（不依赖具体值判断），可直接使用 CompletableFuture.anyOf()：
CompletableFuture<Object> firstCompleted = CompletableFuture.anyOf(futures.toArray(new CompletableFuture[0])); String result = (String) firstCompleted.get(); // 注意类型转换与空值检查
但此方式无法过滤失败结果（如 null 或异常），且返回类型为 Object，需额外处理，灵活性不如 anyMatch。
综上，CompletableFuture 配合自定义 anyMatch 是兼顾简洁性、可控性与健壮性的最佳实践，真正实现“谁先达标谁胜出，其余自动退场”的并发语义。
