CompletableFuture提供声明式异步编程，支持链式调用、任务组合与异常处理，通过supplyAsync/runAsync执行任务，结合thenApply/thenCombine实现串行或并行编排，使用exceptionally/handle处理错误，推荐自定义线程池以提升性能。
在现代Java应用开发中，异步编程已成为提升系统吞吐量和响应速度的关键手段。传统的多线程方式虽然可行，但代码复杂、难以管理回调和异常。Java 8引入的 CompletableFuture 类，为异步任务执行提供了强大且简洁的API支持，极大简化了并发编程的实现。
CompletableFuture简介
CompletableFuture 是对 Future 的增强，实现了 Future 和 CompletionStage 接口。它允许你以声明式的方式组合多个异步操作，支持链式调用、回调处理、异常处理以及任务编排。
相比原始的 Future，CompletableFuture 提供了以下优势：
- 支持非阻塞的回调机制（如 thenApply、thenAccept、thenRun）
- 可组合多个异步任务（thenCompose、thenCombine）
- 支持任务完成时的处理（whenComplete、exceptionally）
- 可以手动完成任务（complete 方法）
- 支持自定义线程池执行
基本异步任务执行
使用 CompletableFuture.supplyAsync() 可启动一个有返回值的异步任务，而 runAsync() 用于无返回值的任务。
立即学习“Java免费学习笔记（深入）”；
// 示例：异步获取用户信息 CompletableFuturefuture = CompletableFuture.supplyAsync(() -> { // 模拟耗时操作 try { Thread.sleep(1000); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } return "User Data"; }); // 非阻塞地处理结果 future.thenAccept(data -> System.out.println("Received: " + data));
默认情况下，这些任务使用 ForkJoinPool.commonPool() 线程池。生产环境中建议传入自定义线程池，避免阻塞公共池中的其他任务。
ExecutorService executor = Executors.newFixedThreadPool(4); CompletableFutureasyncTask = CompletableFuture.supplyAsync(() -> { return 2 + 3; }, executor); // 记得关闭线程池 executor.shutdown();
任务编排与组合
实际业务中，往往需要多个异步任务协同工作。CompletableFuture 提供了多种组合方式：
AJAX即“Asynchronous Javascript And XML”（异步JavaScript和XML），是指一种创建交互式网页应用的网页开发技术。它不是新的编程语言，而是一种使用现有标准的新方法，最大的优点是在不重新加载整个页面的情况下，可以与服务器交换数据并更新部分网页内容，不需要任何浏览器插件，但需要用户允许JavaScript在浏览器上执行。《php中级教程之ajax技术》带你快速
串行执行（thenApply / thenCompose）
CompletableFutureresult = CompletableFuture .supplyAsync(() -> "Hello") .thenApply(s -> s + " World") .thenApply(String::toUpperCase);
并行执行并合并结果（thenCombine）
CompletableFuturetask1 = CompletableFuture.supplyAsync(() -> 10); CompletableFuture task2 = CompletableFuture.supplyAsync(() -> 20); CompletableFuture sum = task1.thenCombine(task2, Integer::sum); sum.thenAccept(total -> System.out.println("Sum: " + total)); // 30
多个任务全部完成（allOf）或任一完成（anyOf）
CompletableFutureallDone = CompletableFuture.allOf(task1, task2); allDone.thenRun(() -> System.out.println("All tasks completed."));
异常处理机制
异步任务中的异常不会自动抛出，必须通过 exceptionally 或 handle 方法显式处理。
CompletableFuturefaulty = CompletableFuture.supplyAsync(() -> { throw new RuntimeException("Something went wrong"); }); faulty .exceptionally(ex -> { System.err.println("Error: " + ex.getMessage()); return "Fallback Value"; }) .thenAccept(System.out::println); // 输出 Fallback Value
也可以使用 handle(BiFunction
CompletableFuture基本上就这些。掌握 CompletableFuture 的核心方法后，就能写出高效、清晰的异步代码，适用于IO密集型服务调用、批量数据处理等场景。关键是理解其非阻塞特性，合理使用线程池，避免资源竞争和内存泄漏。handled = future.handle((result, ex) -> { if (ex != null) { return "Error occurred: " + ex.getMessage(); } return "Success: " + result; });
