completablefuture.anyof() 用于接收多个 completablefuture 对象，并返回一个新的 completablefuture。这个新任务会在所有输入任务中**任意一个**完成时立即触发（无论是正常返回还是抛出异常），其结果即为那个最先完成的任务的返回值。
如何调用 anyOf 并获取最快结果
调用方式是将多个 CompletableFuture 实例作为可变参数传入静态方法 anyOf。它会返回一个类型为 Object 的 CompletableFuture，你需要通过 get() 或 获取实际值。如果最快的任务抛出了异常，<code>get() 会抛出 ExecutionException，其中包含原始异常。
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class AnyOfDemo {
public static void main(String[] args) throws ExecutionException, InterruptedException {
// 模拟三个耗时不同的异步任务
CompletableFuture<String> task1 = CompletableFuture.supplyAsync(() -> {
try { Thread.sleep(3000); } catch (InterruptedException e) {}
return "Task 1 Result";
});
CompletableFuture<String> task2 = CompletableFuture.supplyAsync(() -> {
try { Thread.sleep(1000); } catch (InterruptedException e) {}
return "Task 2 Result";
});
CompletableFuture<String> task3 = CompletableFuture.supplyAsync(() -> {
try { Thread.sleep(2000); } catch (InterruptedException e) {}
return "Task 3 Result";
});
// 使用 anyOf 获取最先完成的任务结果
CompletableFuture<Object> fastest = CompletableFuture.anyOf(task1, task2, task3);
// 阻塞等待直到有一个完成
Object result = fastest.get();
System.out.println("Fastest result: " + result);
// 预期输出: Fastest result: Task 2 Result
}
}如何处理 anyOf 中的异常
当最先完成的任务是异常结束时，anyOf 返回的 CompletableFuture 也会处于异常状态。此时直接调用 get() 会抛出 ExecutionException。为了优雅处理，可以使用 exceptionally() 或 handle() 进行回调处理，这样可以在不阻塞主线程的情况下捕获并转换错误信息。
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class AnyOfExceptionDemo {
public static void main(String[] args) {
CompletableFuture<String> failingTask = CompletableFuture.supplyAsync(() -> {
throw new RuntimeException("Task failed!");
});
CompletableFuture<String> successTask = CompletableFuture.supplyAsync(() -> {
try { Thread.sleep(5000); } catch (InterruptedException e) {}
return "Success";
});
// anyOf 会捕捉到 failingTask 的异常
CompletableFuture<Object> anyResult = CompletableFuture.anyOf(failingTask, successTask);
// 使用 exceptionally 处理异常
anyResult.exceptionally(ex -> {
System.out.println("Caught exception: " + ex.getCause().getMessage());
return "Fallback Value";
}).thenAccept(res -> {
System.out.println("Final result: " + res);
});
// 保持主线程存活以观察输出
try { Thread.sleep(6000); } catch (InterruptedException e) {}
}
}anyOf 返回值的类型是什么
anyOf 方法签名为 static CompletableFuture<object> anyOf(CompletableFuture...>... futures)</object>。无论传入的任务泛型是什么（如 String, Integer），返回的 CompletableFuture 的泛型类型始终固定为 Object。这是因为在编译期无法确定哪个任务会最先完成，因此无法推断具体的返回类型。开发者在获取结果后，通常需要进行强制类型转换或使用 instanceof 检查。
