结合回调函数处理异步任务结果的过程可以比作在等待一份重要的快递时安排一个通知服务。这个通知服务就是回调函数，它会在快递送达时通知你，或者在处理完成后执行特定的操作。
在 Java 的 CompletableFuture 中，这种模式可以通过 supplyAsync() 、thenApply()、thenAccept() 和 handle() 方法来实现。
创建一个异步任务时，使用 CompletableFuture.supplyAsync() 可以启动一个任务，这个任务在后台线程中执行，直到它完成。假设有一个任务需要从远程服务器获取数据：
// supplyAsync() 方法接收一个 Supplier 函数，这个函数会在后台线程中运行，并返回一个结果
// 结果会被封装在 CompletableFuture 对象中，等待进一步处理
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
// 模拟从远程服务器获取数据
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return "数据已成功获取";
});
使用 thenApply() 方法，可以在异步任务完成后，对结果进行转换。这个方法接收一个 Function 函数，这个函数会接收任务的结果，并返回一个新结果。比如，将获取的数据进行处理：
// thenApply() 方法将原始数据转换为大写形式
// 处理后的结果会成为新的 CompletableFuture 对象的结果
CompletableFuture<String> processedFuture = future.thenApply(result -> {
// 对结果进行处理
return result.toUpperCase();
});
为了执行一个操作而不关心处理的结果，可以使用 thenAccept() 方法。这个方法接收一个 Consumer 函数，它处理任务完成时的结果，可以在异步任务完成时执行一些操作，比如日志记录或通知用户。例如，将结果打印到控制台：
// 在任务完成后会调用传入的 Consumer 函数，并将结果传递给它
future.thenAccept(result -> {
System.out.println("任务完成，结果是：" + result);
});
在任务执行过程中，可能会遇到异常。handle() 方法可以用来处理这些异常，它接收一个 BiFunction 函数，这个函数接收结果和异常（如果有的话），并返回一个处理后的结果。例如：
// handle() 方法检查是否有异常发生
// 如果有异常，它会处理异常并返回一个默认的结果
// 如果没有异常，它会处理正常的结果
CompletableFuture<String> handledFuture = future.handle((result, ex) -> {
if (ex != null) {
// 处理异常
System.out.println("任务发生错误：" + ex.getMessage());
return "错误处理结果";
}
// 处理正常结果
return result.toLowerCase();
});
对于这四种回调函数，可以使得异步任务的结果处理变得灵活而强大。通过结合使用不同的回调函数，可以对异步任务的结果进行多种操作，保证程序在处理复杂任务时仍然保持清晰和高效。
4 如何组合并处理多个 CompletableFuture？
组合和处理多个 CompletableFuture 可以让并发任务变得更加灵活和高效。设想有多个任务需要并行执行，然后将它们的结果结合起来进行进一步处理。
在进行组合时，最基本的方法之一是将多个 CompletableFuture 的结果合并。比如，有两个任务需要并行完成，获取两个不同的数据源，然后将这两个结果结合起来。
可以使用 thenCombine() 方法，它接收两个 CompletableFuture 和一个合并函数，两个 CompletableFuture 必须在相同的线程池中执行。
假设有两个任务分别从不同的 API 获取数据：
CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> {
// 模拟从第一个 API 获取数据
return "数据1";
});
CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> {
// 模拟从第二个 API 获取数据
return "数据2";
});
为了将这两个结果结合起来，可以使用 thenCombine()：
// thenCombine() 方法接收两个 CompletableFuture 和一个函数，这个函数将两个任务的结果合并成一个结果
// 最终的结果是将两个字符串连接在一起
CompletableFuture<String> combinedFuture = future1.thenCombine(future2, (result1, result2) -> {
// 将两个结果结合成一个
return result1 + " 和 " + result2;
});
另一个有用的方法是 allOf()方法。当有多个任务需要并行执行，并且在所有任务完成后执行某个操作时，allOf() 非常有用。它接收一个 CompletableFuture 数组，并在所有这些 CompletableFuture 完成时触发。可以用来等待多个异步任务完成，然后执行某个操作：
CompletableFuture<Void> allOfFuture = CompletableFuture.allOf(future1, future2);
1
要获取所有任务的结果，可以在 allOf() 的结果上添加一个回调函数：
// thenRun() 方法会在所有任务完成后执行，它不需要处理结果，只是执行某个操作
allOfFuture.thenRun(() -> {
// 处理所有任务完成后的操作
try {
String result1 = future1.get();
String result2 = future2.get();
System.out.println("任务1的结果: " + result1);
System.out.println("任务2的结果: " + result2);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
});