面试题：Java中CompletableFuture链式调用的错误恢复机制

在CompletableFuture链式调用中，当某个环节任务抛出异常时，可以使用exceptionally方法来捕获异常并进行错误处理和恢复，同时将错误信息传递到链式调用的最后。以下是完整代码示例及解释：

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public class CompletableFutureErrorHandling {

    public static void main(String[] args) {
        CompletableFuture.supplyAsync(() -> {
            // 模拟异步任务1
            System.out.println("任务1开始执行");
            if (Math.random() < 0.5) {
                throw new RuntimeException("任务1发生异常");
            }
            return "任务1执行结果";
        })
       .thenApply(result -> {
            // 模拟异步任务2，依赖任务1的结果
            System.out.println("任务2开始执行，输入: " + result);
            return result + " -> 任务2处理后";
        })
       .exceptionally(ex -> {
            // 捕获前面任务的异常
            System.out.println("捕获到异常: " + ex.getMessage());
            // 进行错误处理和恢复
            return "错误处理结果";
        })
       .thenApply(finalResult -> {
            // 模拟最后一个任务，无论前面是否有异常都执行
            System.out.println("最后任务开始执行，输入: " + finalResult);
            return finalResult + " -> 最后任务处理后";
        })
       .thenAccept(System.out::println)
       .join();
    }
}

代码解释

supplyAsync: 创建一个异步任务，该任务会在一个新线程中执行。这里模拟了一个可能会抛出异常的任务1。
thenApply: 依赖前一个任务的结果，继续执行下一个异步任务。这里模拟了任务2，它会使用任务1的结果进行处理。
exceptionally: 捕获前面任务抛出的异常。当任务1或任务2抛出异常时，会进入这个方法。在这里可以进行错误处理和恢复操作，并返回一个结果，这个结果会作为后续任务的输入。
thenApply: 无论前面任务是否发生异常，都会执行这个任务。这里使用exceptionally处理后的结果或者正常任务链的结果进行最后的处理。
thenAccept: 消费最终的结果并打印。
join: 等待整个CompletableFuture链执行完毕。

通过这种方式，可以确保在异步任务链式调用中，异常能够被捕获、处理并将错误信息传递到链式调用的最后。

星途面试题库

面试题：Java中CompletableFuture链式调用的错误恢复机制

知识考点

面试题答案

代码解释