CompletionStage和异常处理

在使用CompletionStage处理异步操作的过程中，可以通过exceptionally、handle和whenComplete等方法来处理异常。

下面是一个简单的示例代码，演示了如何使用CompletionStage处理异步操作并处理异常：

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionException;
import java.util.concurrent.CompletionStage;

public class ExceptionHandlingExample {

    public static void main(String[] args) {
        // 创建一个CompletableFuture并使用thenApplyAsync进行异步操作
        CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
            // 这里抛出一个异常
            throw new RuntimeException("Some error occurred");
        });

        // 使用exceptionally处理异常
        CompletionStage<Integer> handledFuture = future.exceptionally(ex -> {
            System.out.println("Exception occurred: " + ex.getMessage());
            return 0; // 返回一个默认值
        });

        // 使用handle处理异常
        CompletionStage<Integer> handledFuture2 = future.handle((result, ex) -> {
            if (ex != null) {
                System.out.println("Exception occurred: " + ex.getMessage());
                return 0; // 返回一个默认值
            }
            return result;
        });

        // 使用whenComplete处理异常
        CompletionStage<Integer> handledFuture3 = future.whenComplete((result, ex) -> {
            if (ex != null) {
                System.out.println("Exception occurred: " + ex.getMessage());
            }
        });

        // 获取处理后的结果
        handledFuture.thenAccept(result -> System.out.println("Handled result: " + result));
        handledFuture2.thenAccept(result -> System.out.println("Handled result 2: " + result));
        handledFuture3.thenAccept(result -> System.out.println("Handled result 3: " + result));

        // 等待异步操作完成
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

在上面的代码中，我们使用CompletableFuture.supplyAsync创建了一个CompletableFuture，并在其中抛出了一个RuntimeException。然后，我们使用exceptionally、handle和whenComplete方法分别处理了异常。在异常处理中，我们可以打印异常信息，或者返回一个默认值来代替异常的结果。

最后，我们使用thenAccept方法获取处理后的结果，并打印出来。

运行上述代码，你将会看到异常被捕获并处理，打印出相应的异常信息以及默认值。