异常处理陷阱
- 异常被吞噬： 在CompletableFuture的异步任务中，如果某个阶段发生异常并且没有适当处理，这个异常可能会被吞噬，导致程序无法正常捕获和处理。例如，如果在一个异步任务中抛出了异常，而后续阶段没有调用exceptionally或handle方法来处理，这个异常将不会传播到外部，也不会被打印或记录。
- 异常处理丢失： 使用exceptionally方法处理异常时，如果处理逻辑不正确，可能会导致异常处理丢失。例如，如果exceptionally方法中只是简单地返回一个默认值而没有记录或传播异常信息，那么原始异常将丢失，后续阶段无法知道异常发生的具体情况。
- 堆栈追踪丢失： 在异步任务中捕获异常并重新抛出时，如果不小心处理，可能会导致堆栈追踪信息丢失。这对于调试和定位问题来说是非常不利的。例如，在thenApply方法中捕获异常并重新抛出时，如果不包含原始异常的堆栈追踪信息，那么调用链的更高层将无法获取完整的异常上下文。
- 异常处理冗长： 在处理多个CompletableFuture链时，如果每个阶段都需要处理异常，代码可能会变得冗长和复杂。每个阶段都需要使用exceptionally或handle方法来处理异常，这不仅增加了代码的复杂性，还降低了代码的可读性和可维护性。
解决方案
- 使用whenComplete方法： whenComplete方法可以在任务完成时触发回调函数，无论是正常完成还是发生异常。通过在whenComplete方法中处理异常，可以确保异常得到正确的传播和处理。例如，可以在回调函数中检查异常参数是否为null，如果不为null，则说明发生了异常，并进行相应的处理。
- 合理使用exceptionally和handle方法： exceptionally方法用于在异步任务发生异常时返回一个默认值或执行其他操作。handle方法则可以处理正常完成和异常完成两种情况。在使用这些方法时，应确保异常信息得到适当的记录和传播，避免异常处理丢失。
- 保留堆栈追踪信息： 在重新抛出异常时，应确保包含原始异常的堆栈追踪信息。这可以通过在捕获异常后，使用新的异常类包装原始异常，并在新异常的构造器中传递原始异常的堆栈追踪信息来实现。
- 优化异常处理逻辑： 对于多个CompletableFuture链的异常处理，可以考虑使用组合模式来优化异常处理逻辑。例如，可以使用thenCompose方法来组合多个异步任务，并在最后一个任务中统一处理异常。这样可以减少代码的冗长性和复杂性，提高代码的可读性和可维护性。
示例代码
以下是一个示例代码，展示了如何使用whenComplete方法来处理CompletableFuture中的异常：
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
public class CompletableFutureExceptionHandling {
public static void main(String[] args) throws ExecutionException, InterruptedException, TimeoutException {
CompletableFuture future = CompletableFuture.supplyAsync(() -> {
throw new RuntimeException("Oops!");
});
CompletableFuture result = future.thenApply(i -> "Success: " + i)
.whenComplete((res, ex) -> {
if (ex != null) {
System.out.println("Error occurred: " + ex.getMessage());
}
});
result.join();
}
} 在这个示例中，当异步任务抛出异常时，whenComplete方法会捕获并处理这个异常，打印出错误信息。这样可以确保异常不会被吞噬，也不会影响程序的正常执行。
总结
在CompletableFuture异步编程中，异常处理是一个需要重点关注的问题。通过合理使用whenComplete、exceptionally和handle方法，并保留堆栈追踪信息，我们可以有效地处理异步任务中的异常，提高程序的稳定性和可靠性。同时，优化异常处理逻辑也可以减少代码的冗长性和复杂性，提高代码的可读性和可维护性。
