网站首页 > 技术文章 正文
在 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:动态组件加载新方案
- 最近发表
-
- fail-safe 和 fail-fast 都是什么鬼?
- 办公小技巧:Word“安全模式”用通透
- 新来的妹子误执行 “rm -rf” !_七零大院新来的小美人是黑道千金
- 如何利用 Python 自动发邮件,打工人福音
- Python内置模块base64 :Base16, Base32, Base64, Base85 编码详解
- java调用API操作GitLab_java调用git的接口
- spingboot 实现导入excel数据生成二维码
- SpringBoot中7个文件上传下载工具
- java项目中接入大模型,简历必备_java介绍项目中做过的模块
- spring boot-MultipartFile 机制_spring boot multipartfile为null
- 标签列表
-
- cmd/c (90)
- c++中::是什么意思 (84)
- 标签用于 (71)
- 主键只能有一个吗 (77)
- c#console.writeline不显示 (95)
- pythoncase语句 (88)
- es6includes (74)
- sqlset (76)
- windowsscripthost (69)
- apt-getinstall-y (100)
- node_modules怎么生成 (87)
- chromepost (71)
- flexdirection (73)
- c++int转char (80)
- mysqlany_value (79)
- static函数和普通函数 (84)
- el-date-picker开始日期早于结束日期 (76)
- asynccallback (71)
- localstorage.removeitem (74)
- vector线程安全吗 (70)
- java (73)
- js数组插入 (83)
- mac安装java (72)
- 查看mysql是否启动 (70)
- 无效的列索引 (74)