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

推荐使用 CompletableFuture 框架进行异步操作，很强很方便

news 2024/10/31 1:03:19

文章目录

- 1. 基础概念
- 2. 创建 CompletableFuture
- - 2.1 异步执行无返回值的任务
  - 2.2 异步执行有返回值的任务
- 3. 组合 CompletableFuture
- - 3.1 顺序组合
  - 3.2 并行组合
- 4. 异常处理
- 5. 等待异步操作完成
- 6. 取消异步操作
- 7. 处理多个 CompletableFuture
- 8. 实际应用示例
- 结论
- 推荐阅读文章

在Java 8及更高版本中， CompletableFuture 提供了一种强大的方式来处理异步编程。它不仅简化了回调，还提供了丰富的API来组合异步操作、处理异常和控制流程。下面介绍几个 CompletableFuture 框架中最常用的几个方法：

1. 基础概念

CompletableFuture 是一个可以异步完成操作的类，它提供了一个可写的 Future。这意味着你可以从异步计算中主动完成结果，或者在计算完成时被动接收结果。

2. 创建 CompletableFuture

2.1 异步执行无返回值的任务

CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {// 执行异步任务
});

2.2 异步执行有返回值的任务

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {// 执行异步任务并返回结果return "Hello, CompletableFuture!";
});

3. 组合 CompletableFuture

3.1 顺序组合

使用 thenApply 方法来顺序组合异步操作，它接收一个函数，该函数会在前一个 CompletableFuture 完成后被调用。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello").thenApplyAsync(s -> s + ", CompletableFuture!");

3.2 并行组合

使用 thenCombine 方法来并行组合异步操作，它接收另一个 CompletableFuture 和一个双函数，该函数会在两个 CompletableFuture 都完成后被调用。

CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "Hello");
CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> 5);
CompletableFuture<String> combined = future1.thenCombine(future2, (s, i) -> s + i);

4. 异常处理

exceptionally 方法可以用来处理 CompletableFuture 中发生的异常。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {throw new RuntimeException("Error!");
}).exceptionally(ex -> {// 处理异常return "Default Value";
});

5. 等待异步操作完成

join 方法可以用来阻塞当前线程直到 CompletableFuture 完成。

String result = future.join(); // 阻塞直到 future 完成

6. 取消异步操作

CompletableFuture 支持取消异步操作。

CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {// 长时间运行的任务
});
future.cancel(true); // 取消任务

7. 处理多个 CompletableFuture

CompletableFuture 提供了 allOf 方法来等待多个异步操作完成。

CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> "Hello");
CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> 5);
CompletableFuture<Void> allFutures = CompletableFuture.allOf(future1, future2);
allFutures.join(); // 等待所有 future 完成

8. 实际应用示例

假设我们需要从两个不同的服务中获取数据，并将结果合并。

CompletableFuture<String> data1 = CompletableFuture.supplyAsync(() -> fetchDataFromService1());
CompletableFuture<String> data2 = CompletableFuture.supplyAsync(() -> fetchDataFromService2());
CompletableFuture<String> combinedData = data1.thenCombine(data2, (s1, s2) -> s1 + " " + s2);
String result = combinedData.join();

结论

CompletableFuture 是Java异步编程的强大工具，它提供了一种简洁且强大的方式来处理异步任务。通过本文的介绍，你应该能够开始在你的项目中使用 CompletableFuture 来简化异步代码，并提高程序的响应性和性能。
不过你得注意异步的时候，上下文无法传递的问题哦。这个你可以通过自定义线程池来解决！