CompletableFuture是Java中用于异步编程的核心工具，实现Future与CompletionStage接口，支持链式调用、任务组合及异常处理。通过supplyAsync和runAsync可创建有返回值或无返回值的异步任务，默认使用ForkJoinPool.commonPool()，也可指定自定义线程池。thenApply、thenAccept、thenRun实现结果转换与消费，thenCombine、thenCompose用于合并或串行依赖任务，allOf和anyOf协调多个任务的执行。异常处理通过exceptionally或handle方法完成，避免阻塞操作如get()，推荐回调方式提升I/O密集型场景下的性能与响应性。
在Java中，CompletableFuture 是处理异步编程的强大工具。它实现了 Future 和 CompletionStage 接口，支持链式调用、组合多个异步任务、异常处理以及回调机制，让非阻塞代码更清晰易读。
创建异步任务
你可以使用 runAsync 或 supplyAsync 启动一个异步操作：
- runAsync：执行无返回值的任务，适合 void 类型的操作。
-
supplyAsync：执行有返回值的任务，返回 CompletableFuture
。
默认情况下，这些方法使用 ForkJoinPool.commonPool() 线程池，但也可以传入自定义线程池以更好控制资源。
示例：
立即学习“Java免费学习笔记（深入）”；
赣极购物商城网店建站软件系统
下载
大小仅1兆左右 ，足够轻便的商城系统； 易部署，上传空间即可用，安全，稳定； 容易操作，登陆后台就可设置装饰网站； 并且使用异步技术处理网站数据，表现更具美感。 前台呈现页面，兼容主流浏览器，DIV+CSS页面设计； 如果您有一定的网页设计基础，还可以进行简易的样式修改，二次开发， 发布新样式，调整网站结构，只需修改css目录中的css.css文件即可。 商城网站完全独立，网站源码随时可供您下载
CompletableFuturefuture = CompletableFuture.runAsync(() -> { System.out.println("任务正在执行..."); }); CompletableFuture supplyFuture = CompletableFuture.supplyAsync(() -> { return "结果已生成"; });
链式调用与结果转换
通过 thenApply、thenAccept 和 thenRun 可以对前一个任务的结果进行后续处理：
- thenApply(Function)：接收上一步结果并返回新值，可用于数据转换。
- thenAccept(Consumer)：消费结果，不返回值，适合打印或存储。
- thenRun(Runnable)：不关心结果，只在前任务完成后执行动作。
示例：
立即学习“Java免费学习笔记（深入）”；
CompletableFutureresult = CompletableFuture .supplyAsync(() -> "Hello") .thenApply(s -> s + " World") .thenApply(String::toUpperCase); result.thenAccept(System.out::println); // 输出: HELLO WORLD
组合多个异步任务
当需要并行执行多个任务并合并结果时，可以使用以下方法：
- thenCombine：合并两个独立的 CompletableFuture 的结果。
- thenCompose：将一个 CompletableFuture 的输出作为另一个的输入（扁平化嵌套）。
- allOf：等待所有 CompletableFuture 完成，适用于并行无依赖任务。
- anyOf：任一任务完成即触发后续操作。
示例：合并两个远程请求结果
CompletableFuturef1 = CompletableFuture.supplyAsync(() -> fetchUser()); CompletableFuture f2 = CompletableFuture.supplyAsync(() -> fetchOrder()); CompletableFuture combined = f1.thenCombine(f2, (user, order) -> "User: " + user + ", Order: " + order ); combined.thenAccept(System.out::println);
异常处理
异步流程中的异常不会自动抛出，必须显式处理。常用方法包括：
- exceptionally(Function)：捕获异常并提供默认值或降级逻辑。
- handle(BiFunction)：无论是否异常都能处理，接收结果和异常两个参数。
示例：
立即学习“Java免费学习笔记（深入）”；
CompletableFuturefaulty = CompletableFuture .supplyAsync(() -> { throw new RuntimeException("网络错误"); }) .exceptionally(ex -> { System.err.println("发生异常: " + ex.getMessage()); return "默认用户"; }); faulty.thenAccept(System.out::println); // 输出: 默认用户
基本上就这些。合理使用 CompletableFuture 能显著提升程序响应性和吞吐量，尤其适合 I/O 密集型场景如 Web 请求、数据库查询等。关键是避免阻塞调用（如 get()），尽量用回调方式处理结果。
