CompletableFuture使用示例-CFANZ编程社区

CompletableFuture是Java 8中引入的一个功能强大的类，它实现了Future和CompletionStage两个接口，主要用于异步编程。通过它，开发者可以以一种非阻塞的方式编写异步代码，从而提高程序的响应速度和资源利用率。

异步执行：

CompletableFuture支持在后台线程中异步执行计算或操作，避免阻塞主线程。
提供了supplyAsync和runAsync两个静态方法用于启动异步任务，其中supplyAsync返回有结果的CompletableFuture，而runAsync返回无结果的CompletableFuture。

可组合性：

CompletableFuture的操作可以组合成一个或多个的CompletableFuture对象，从而构成复杂的异步计算链。
提供了多种组合方法，如thenCombine、thenAcceptBoth、thenApply、thenCompose等，允许开发者灵活地编排和组合多个异步任务。

异常处理：

CompletableFuture提供了丰富的异常处理机制，包括exceptionally和handle方法。
exceptionally方法用于捕获异步任务执行过程中的异常，并返回一个默认值或处理后的结果。
handle方法不仅可以处理异常，还可以处理正常的计算结果，提供了一种更灵活的方式来处理异步任务的结果。

取消与超时：

支持取消异步任务，通过调用cancel方法可以实现。
提供了超时控制功能，可以通过设置超时时间来避免任务的无限等待。

非阻塞式等待：

提供了非阻塞式的等待方法，如join和getNow（注意：getNow方法在标准Java API中并不直接存在，但类似的概念可以通过其他方式实现，如结合get方法和超时控制）。
这些方法允许开发者在不阻塞当前线程的情况下等待异步任务的结果。

以下是一个简单的CompletableFuture使用示例，展示了如何启动异步任务、处理结果和异常：

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public class CompletableFutureExample {
    public static void main(String[] args) {
        // 启动一个异步任务，该任务返回一个字符串结果
        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
            // 模拟异步操作，例如网络请求、数据库查询等
            try {
                Thread.sleep(1000); // 模拟耗时操作
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
            return "Hello, CompletableFuture!";
        });

        // 处理异步任务的结果
        future.thenAccept(result -> System.out.println(result))
              .exceptionally(e -> {
                  System.err.println("异步任务发生异常: " + e.getMessage());
                  return null; // 注意：这里返回null是因为thenAccept不返回新的CompletableFuture
              });

        // 注意：在实际应用中，你可能需要等待异步任务完成。这里为了演示方便，没有显式等待。
        // 在实际场景中，可以通过future.join()或future.get()等方法来等待异步任务的结果。
    }
}

四、总结

CompletableFuture是Java 8中引入的一个非常重要的异步编程工具，它提供了丰富的API来支持异步任务的执行、组合、异常处理等功能。通过使用CompletableFuture，开发者可以编写出更加高效、灵活和易于管理的异步代码。