当前位置：首页 > news >正文

异步CompletableFuture最常用的用法

news 2026/7/21 13:50:07

下面用「核心场景 + 极简代码 + 一句话说明」的形式，把CompletableFuture最常用的用法拆得更清晰，只保留核心逻辑，去掉冗余：

一、最基础：创建异步任务（核心中的核心）

场景 1：无返回值（比如广告统计、日志记录）

// 推荐：自定义线程池（避免默认池耗尽） Executor pool = Executors.newFixedThreadPool(3); CompletableFuture.runAsync(() -> { // 要异步执行的代码（比如统计广告数据） System.out.println("异步执行无返回值任务"); }, pool); // 极简版（临时测试用） CompletableFuture.runAsync(() -> System.out.println("异步执行无返回值任务"));

一句话：runAsync+ 任务代码 + （可选）自定义线程池，执行完就结束，不用返回结果。

场景 2：有返回值（比如异步查数据库、调接口）

Executor pool = Executors.newFixedThreadPool(3); CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> { // 异步执行并返回结果（比如查数据库返回字符串） return "异步任务的返回结果"; }, pool); // 极简版 CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "返回结果");

一句话：supplyAsync+ 有返回值的代码，能拿到异步任务的结果。

二、拿到结果后：怎么处理（链式操作）

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "hello"); // 1. 转换结果（比如把hello变成hello world） future.thenApply(str -> str + " world"); // 有返回值 // 2. 消费结果（比如打印、存日志，不用返回） future.thenAccept(str -> System.out.println("拿到结果：" + str)); // 无返回值 // 3. 任务完事后执行（不管结果，比如弹个提示） future.thenRun(() -> System.out.println("任务执行完了")); // 无返回值

一句话：

thenApply：改结果、有返回；
thenAccept：用结果、无返回；
thenRun：只执行、不关心结果。

三、多任务配合：多个异步任务怎么协同

CompletableFuture<String> task1 = CompletableFuture.supplyAsync(() -> "任务1结果"); CompletableFuture<Integer> task2 = CompletableFuture.supplyAsync(() -> 2); // 1. 串联执行（任务1的结果传给任务2） task1.thenCompose(res1 -> CompletableFuture.supplyAsync(() -> res1 + "-任务2")); // 2. 合并结果（任务1和任务2都做完，合并结果） task1.thenCombine(task2, (res1, res2) -> res1 + res2); // 结果：任务1结果2 // 3. 等所有任务做完（比如批量处理10个异步任务） CompletableFuture.allOf(task1, task2).join(); // 阻塞等task1、task2都完成 // 4. 只要有一个任务做完（比如多接口抢结果） CompletableFuture.anyOf(task1, task2); // 谁先做完就用谁的结果

一句话：

thenCompose：任务串着来；
thenCombine：任务并行做、合并结果；
allOf：等所有任务；
anyOf：等第一个完成的任务。

四、必加：异常处理（避免异步异常丢了）

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> { throw new RuntimeException("任务出错了"); // 模拟异常 }); // 1. 异常兜底（出错了返回默认值） future.exceptionally(e -> { System.err.println("捕获异常：" + e.getMessage()); return "出错后的默认值"; // 异常时返回这个值 }); // 2. 完成回调（不管成功/失败都执行） future.whenComplete((res, e) -> { if (e != null) { System.err.println("任务失败：" + e.getMessage()); } else { System.out.println("任务成功：" + res); } });

一句话：

exceptionally：出错了给个兜底值；
whenComplete：成功 / 失败都能处理。

五、最后：怎么拿结果（尽量少阻塞）

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "返回结果"); // 1. 阻塞拿（简单，推荐用这个） String res1 = future.join(); // 出错抛运行时异常，不用try-catch // 2. 超时拿（防止卡死，更安全） String res2 = future.get(1, TimeUnit.SECONDS); // 1秒拿不到就抛超时异常，需try-catch // 3. 非阻塞拿（拿不到就给默认值） String res3 = future.getNow("默认值"); // 任务没做完就返回"默认值"

一句话：