Java中如何使用CompletableFuture的whenComplete和exceptionally函数进行异常处理

在java的异步编程中，completablefuture是一个很有用的类，它可以帮助我们在异步操作完成之后进行回调，并且有很好的异常处理机制。本文将介绍如何使用completablefuture的whencomplete和exceptionally函数进行异常处理。

1. CompletableFuture的whenComplete函数

CompletableFuture的whenComplete函数是一个回调函数，当异步操作完成之后，它会被调用。当异步操作正常完成时，当Complete的第一个参数是异步操作的结果，我们可以在回调函数中对结果进行操作。当异步操作失败时，它会将异常作为whenComplete的第二个参数传递给回调函数。

示例代码：

CompletableFuture future = CompletableFuture.supplyAsync(() -> {
    return "hello world";
});
future.whenComplete((result, throwable) -> {
    if (throwable == null) {
        System.out.println("result: " + result);
    } else {
        System.out.println("exception: " + throwable.getMessage());
    }
});

在上面的代码中，我们首先创建了一个CompletableFuture实例，并使用supplyAsync方法异步执行了一个任务，这个任务返回了一个字符串"hello world"。我们使用whenComplete函数作为回调函数，在异步操作完成之后进行处理。如果异步操作正常完成，我们打印出结果；如果异步操作失败，我们打印出异常的信息。

2. CompletableFuture的exceptionally函数

CompletableFuture的exceptionally函数也是一个回调函数，但是它只会在异步操作出现异常时被调用。它的返回值是一个新的CompletableFuture实例，用于处理异常的情况。我们可以在exceptionally函数中对异常进行处理，并返回一个默认值或者其他的值。

立即学习“Java免费学习笔记（深入）”；

PPT.AI

AI PPT制作工具

下载

示例代码：

CompletableFuture future = CompletableFuture.supplyAsync(() -> {
    throw new RuntimeException("exception occurred");
});
CompletableFuture result = future.exceptionally(throwable -> {
    return "default value";
});
result.whenComplete((value, throwable) -> {
    if (throwable == null) {
        System.out.println("result: " + value);
    } else {
        System.out.println("exception: " + throwable.getMessage());
    }
});

在上面的代码中，我们使用了supplyAsync方法执行一个会抛出异常的任务。我们使用exceptionally函数来处理异常情况，它的返回值是一个新的CompletableFuture实例。在回调函数中，我们可以对结果进行处理。如果异常没有被捕获，我们将打印出异常信息；如果异常被捕获并处理，我们将打印出返回的默认值。

总结

本文介绍了如何使用CompletableFuture的whenComplete和exceptionally函数进行异常处理。使用CompletableFuture的异步回调函数和异常处理机制可以大大提高Java的异步编程效率和可靠性。