网站首页 > 技术文章 正文
在 Java 8 中,CompletableFuture 没有提供原生的 failedFuture() 方法(该方法在 Java 9 引入)。以下是几种在 Java 8 中实现相同功能的替代方案:
方案 1:手动创建异常完成的 Future(最常用)
public static <T> CompletableFuture<T> failedFuture(Throwable ex) {
CompletableFuture<T> future = new CompletableFuture<>();
future.completeExceptionally(ex);
return future;
}
// 使用示例
CompletableFuture<String> future = failedFuture(new IOException("Connection failed"));
future.exceptionally(e -> {
System.err.println("Error: " + e.getMessage());
return null;
});
方案 2:使用 supplyAsync 包装异常
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
throw new RuntimeException("Forced failure");
});
// 异常处理
future.handle((result, ex) -> {
if (ex != null) {
System.out.println("Caught: " + ex.getCause().getMessage());
}
return result;
});
方案 3:组合操作(更复杂的场景)
// 先创建正常 Future 再组合异常
CompletableFuture<String> success = CompletableFuture.completedFuture("OK");
CompletableFuture<String> failure = success.thenApply(s -> {
throw new IllegalStateException("Transformed to failure");
});
// 统一处理
failure.exceptionally(ex -> {
System.out.println("Transformed error: " + ex.getMessage());
return "fallback";
});
方案 4:使用第三方库(如 Guava)
// 添加 Guava 依赖
import com.google.common.util.concurrent.SettableFuture;
SettableFuture<String> future = SettableFuture.create();
future.setException(new RuntimeException("Guava failure"));
// 转成 CompletableFuture
CompletableFuture<String> completable = CompletableFuture.supplyAsync(() -> {
try {
return future.get();
} catch (Exception e) {
throw new CompletionException(e);
}
});
对比总结
方法 | 优点 | 缺点 |
手动创建异常 Future | 简单直接,无依赖 | 需自定义工具方法 |
supplyAsync 包装异常 | 无需额外方法 | 异常堆栈可能包含冗余信息 |
组合操作 | 适合已有 Future 的转换 | 代码稍复杂 |
Guava 库 | 功能强大 | 引入第三方依赖 |
Java 9+ 原生方法(参考)
// Java 9+ 原生方法
CompletableFuture<String> failure = CompletableFuture.failedFuture(
new IOException("File not found")
);
迁移建议:
- 若项目停留在 Java 8,推荐使用 方案 1(自定义工具方法)
- 若可升级到 Java 9+,直接使用原生 failedFuture()
- 若已使用 Guava,可考虑 方案 4 保持风格统一
猜你喜欢
- 2025-07-14 harmony-utils之PickerUtil,拍照、文件选择和保存,工具类
- 2025-07-14 Java异步编程7大夺命坑!阿里P8血泪逃生指南(附性能核弹包)
- 2025-07-14 Nuxt错误处理完整指南:从基础到高级实践
- 2025-07-14 webpack的几个常见loader源码浅析,动手实现一个md2html-loader
- 2025-07-14 async/await 在 C# 语言中是如何工作的?(中)
- 2025-07-14 Vue3 远程加载组件(vue3远程加载组件)
- 2025-07-14 用 async 模块控制并发数(@async 并发100000)
- 2025-07-14 webpack 常见loader原理剖析,动手实现一个md2html的loader
- 2025-07-14 Vue 3最佳实践:10万QPS性能调优手册
- 2025-07-14 Teleport+Suspense:动态组件加载新方案
- 1512℃桌面软件开发新体验!用 Blazor Hybrid 打造简洁高效的视频处理工具
- 556℃Dify工具使用全场景:dify-sandbox沙盒的原理(源码篇·第2期)
- 504℃MySQL service启动脚本浅析(r12笔记第59天)
- 482℃服务器异常重启,导致mysql启动失败,问题解决过程记录
- 480℃启用MySQL查询缓存(mysql8.0查询缓存)
- 460℃「赵强老师」MySQL的闪回(赵强iso是哪个大学毕业的)
- 441℃mysql服务怎么启动和关闭?(mysql服务怎么启动和关闭)
- 438℃MySQL server PID file could not be found!失败
- 最近发表
- 标签列表
-
- c++中::是什么意思 (83)
- 标签用于 (65)
- 主键只能有一个吗 (66)
- c#console.writeline不显示 (75)
- pythoncase语句 (81)
- es6includes (73)
- windowsscripthost (67)
- apt-getinstall-y (86)
- node_modules怎么生成 (76)
- c++int转char (75)
- static函数和普通函数 (76)
- el-date-picker开始日期早于结束日期 (70)
- js判断是否是json字符串 (67)
- checkout-b (67)
- c语言min函数头文件 (68)
- asynccallback (71)
- localstorage.removeitem (74)
- vector线程安全吗 (70)
- & (66)
- java (73)
- js数组插入 (83)
- mac安装java (72)
- eacces (67)
- 查看mysql是否启动 (70)
- 无效的列索引 (74)