CompletableFuture简介
CompletableFuture是Java并发API的一部分，它代表了异步计算的结果，并且可以对结果进行进一步的处理。与Future相比，CompletableFuture提供了更多的方法来处理异步操作，例如组合操作、异常处理、超时控制等。
基本使用方法
创建CompletableFuture
可以通过多种方式创建CompletableFuture：
CompletableFuture future = CompletableFuture.supplyAsync(() -> {
// 模拟耗时操作
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
return "Hello, CompletableFuture!";
}); 处理结果
使用thenApply方法来处理异步操作的结果：
future.thenApply(s -> s.toUpperCase())
.thenAccept(System.out::println)
.join(); // 等待结果完成异常处理
使用exceptionally方法来处理异步操作中的异常：
future.exceptionally(ex -> {
System.err.println("Error occurred: " + ex.getMessage());
return "Default Value";
});组合CompletableFuture
组合多个CompletableFuture
使用allOf和anyOf方法来组合多个CompletableFuture：
CompletableFuture allFutures = CompletableFuture.allOf(future1, future2, future3);
CompletableFuture 顺序执行
使用thenCompose方法来顺序执行异步操作：
CompletableFuture result = CompletableFuture.supplyAsync(() -> "First")
.thenCompose(s -> CompletableFuture.supplyAsync(() -> s + " Th
en")); 错误处理和超时
错误处理
使用handle方法来同时处理结果和异常：
future.handle((s, t) -> {
if (t != null) {
System.err.println("Error: " + t.getMessage());
return "Error";
}
return s;
});设置超时
使用orTimeout方法来设置异步操作的超时时间：
CompletableFuture timedOutFuture = future.orTimeout(50
0, TimeUnit.MILLISECONDS); 使用自定义线程池
使用自定义的Executor来控制CompletableFuture使用的线程池：
Executor executor = Executors.newFixedThreadPool(4);
CompletableFuture customFuture = CompletableFuture.supplyAsync(() -> {
// 异步操作
return "Custom Thread Pool Result";
}, executor); 响应式编程集成
如果你的应用程序已经在使用响应式编程库，如RxJava或Project Reactor，可以使用这些库的适配器来与CompletableFuture集成。
CompletableFuture提供了一种强大且灵活的方式来处理Java中的异步编程。通过上述示例，我们可以看到它如何简化异步操作的处理，提高代码的可读性和可维护性。
在实际开发中，合理使用CompletableFuture不仅可以提升程序的性能，还能增强代码的健壮性和可读性。
