Java 如何实现异步编程？

Question

Java 如何实现异步编程？

仓乃文 · Accepted Answer

Java 异步编程推荐使用 CompletableFuture，支持链式调用、组合多个异步任务和异常处理，比 Future 更灵活。基础异步调用： ```java import java.util.concurrent.CompletableFuture; // 异步执行任务 CompletableFuture future = CompletableFuture.supplyAsync(() -> { // 模拟耗时操作 Thread.sleep(1000); return "结果"; }); // 链式处理结果 future.thenApply(result -> result + " 已处理") // 转换结果 .thenAccept(System.out::println) // 消费结果 .join(); // 等待完成 ``` 组合多个异步任务： ```java CompletableFuture task1 = CompletableFuture.supplyAsync(() -> "Hello"); CompletableFuture task2 = CompletableFuture.supplyAsync(() -> "World"); // 等待两个任务都完成，合并结果 task1.thenCombine(task2, (r1, r2) -> r1 + " " + r2) .thenAccept(System.out::println); // "Hello World" // 任一任务完成即返回 CompletableFuture.anyOf(task1, task2) .thenAccept(result -> System.out.println("最快的结果: " + result)); ``` 异常处理： ```java CompletableFuture.supplyAsync(() -> { if (Math.random() > 0.5) throw new RuntimeException("出错了"); return "成功"; }) .exceptionally(ex -> "降级结果") // 异常时返回默认值 .thenAccept(System.out::println); ``` 补充说明： - supplyAsync 有返回值，runAsync 无返回值 - 默认使用 ForkJoinPool.commonPool()，可传入自定义线程池 - thenApply 同步转换，thenApplyAsync 异步转换 - allOf 等待所有完成，anyOf 等待任一完成