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

在线做文档的网站凡客建站

wzjs 2025/8/17 16:54:23

在线做文档的网站,凡客建站,西安网站建设开发制作,网站制作的软件有哪些精心整理了最新的面试资料和简历模板，有需要的可以自行获取点击前往百度网盘获取点击前往夸克网盘获取一、CompletableFuture 概述 CompletableFuture是Java 8引入的异步编程工具类，实现了Future和CompletionStage接口，支持链式调用、组…

精心整理了最新的面试资料和简历模板，有需要的可以自行获取

点击前往百度网盘获取
点击前往夸克网盘获取

一、CompletableFuture 概述

CompletableFuture是Java 8引入的异步编程工具类，实现了Future和CompletionStage接口，支持链式调用、组合操作和异常处理，能够优雅地解决多任务编排问题。相比传统的Future，它具备以下优势：

非阻塞调用：通过回调机制避免线程等待
链式编程：支持任务流水线处理
组合操作：可合并多个异步任务结果
异常隔离：提供独立的异常处理通道

二、核心用法详解

1. 基础任务创建

// 创建并立即执行异步任务（默认使用ForkJoinPool）
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {// 模拟耗时操作try { Thread.sleep(1000); } catch (InterruptedException e) {}return "Result";
});// 同步获取结果（会阻塞线程）
String result = future.get(); // 异步回调处理
future.thenAccept(r -> System.out.println("Received: " + r));

2. 常用操作方法

结果转换（thenApply）

CompletableFuture<Integer> lengthFuture = future.thenApply(s -> s.length());

结果消费（thenAccept/thenRun）

future.thenAccept(result -> saveToDB(result)); // 消费结果
future.thenRun(() -> cleanupResources());      // 无参回调

异常处理

future.exceptionally(ex -> {System.err.println("Error: " + ex.getMessage());return "Fallback Value";
});

三、组合操作实践

1. 任务聚合

// 等待所有任务完成
CompletableFuture<Void> all = CompletableFuture.allOf(future1, future2);
all.thenRun(() -> {String res1 = future1.join();String res2 = future2.join();
});// 任意任务完成即触发
CompletableFuture<Object> any = CompletableFuture.anyOf(futureA, futureB);

2. 任务链式组合

CompletableFuture.supplyAsync(() -> fetchUserInfo()).thenApply(user -> processData(user)).thenCompose(processed -> saveToDatabase(processed)).thenAccept(id -> sendNotification(id)).exceptionally(ex -> handleError(ex));

四、典型使用场景

1. 并行IO操作

CompletableFuture<String> apiCall1 = CompletableFuture.supplyAsync(this::callAPI1);
CompletableFuture<String> apiCall2 = CompletableFuture.supplyAsync(this::callAPI2);apiCall1.thenCombine(apiCall2, (res1, res2) -> combineResults(res1, res2)).thenAccept(this::showFinalResult);

2. 超时控制（Java 9+）

future.orTimeout(2, TimeUnit.SECONDS).exceptionally(ex -> "Timeout Fallback");

五、工具类封装示例

public class AsyncUtils {private static final Executor customExecutor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() * 2);public static <T> CompletableFuture<T> supplyAsync(Callable<T> task) {return CompletableFuture.supplyAsync(() -> {try {return task.call();} catch (Exception e) {throw new CompletionException(e);}}, customExecutor);}public static CompletableFuture<Void> runAsync(Runnable task) {return CompletableFuture.runAsync(task, customExecutor);}
}