completablefuture.anyof() 用于接收多个 completablefuture 对象，并返回一个新的 completablefuture。这个新任务会在所有输入任务中**任意一个**完成时立即触发（无论是正常返回还是抛出异常），其结果即为那个最先完成的任务的返回值。

如何调用 anyOf 并获取最快结果

调用方式是将多个 CompletableFuture 实例作为可变参数传入静态方法 anyOf。它会返回一个类型为 Object 的 CompletableFuture，你需要通过 get() 或 获取实际值。如果最快的任务抛出了异常，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
    }
}</object></string></string></string>

如何处理 anyOf 中的异常

当最先完成的任务是异常结束时，anyOf 返回的 CompletableFuture 也会处于异常状态。此时直接调用 get() 会抛出 ExecutionException。为了优雅处理，可以使用 exceptionally() 或 handle() 进行回调处理，这样可以在不阻塞主线程的情况下捕获并转换错误信息。

Java调试

通过 JDWP 实现 Java 远程调试：连接远程 JVM、设置断点、单步执行代码、查看变量值、获取调用栈。适用于需要调试远程 Java 应用、排查运行时状态、追踪代码执行流程的场景。 术语注解 JDWP：Java Debug Wire Protocol，Java 调试有线协议（Java 远程调试底层通信协议） remote JVM：远程 Java 虚拟机 step through code：代码单步调试（步入 / 步过 / 步出调试） inspect variables：变量查看 / 变量检视 stac

下载

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) {}
    }
}</object></string></string>

anyOf 返回值的类型是什么

anyOf 方法签名为 static CompletableFuture。无论传入的任务泛型是什么（如 String, Integer），返回的 CompletableFuture 的泛型类型始终固定为 Object。这是因为在编译期无法确定哪个任务会最先完成，因此无法推断具体的返回类型。开发者在获取结果后，通常需要进行强制类型转换或使用 instanceof 检查。

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南