网站首页 > 技术文章 正文
在 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-09-18 GPU集群扩展:Ray Serve与Celery的技术选型与应用场景分析
- 2025-09-18 【不背八股】2.操作系统-进程、线程、协程的基本理解
- 2025-09-18 两张图看透Android Handler使用与机制
- 2025-09-18 Spring Boot 3.x 日志配置与 Logback 集成指南
- 2025-09-18 解锁C++异步之力:高效并发编程指南
- 2025-09-18 Flutter框架分析(八)-Platform Channel
- 2025-09-18 原来你是这样打印日志的,怪不得天天背锅……
- 2025-09-18 .NET Aspire 9.4 发布了 CLI GA、交互式仪表板和高级部署功能
- 2025-09-18 27.8K!一把梭 LLM:LiteLLM 带你用一套接口召唤 100+ 大模型
- 2025-09-18 Rust异步编程神器:用Tokio轻松创建定时任务
- 最近发表
-
- 聊一下 gRPC 的 C++ 异步编程_grpc 异步流模式
- [原创首发]安全日志管理中心实战(3)——开源NIDS之suricata部署
- 超详细手把手搭建在ubuntu系统的FFmpeg环境
- Nginx运维之路(Docker多段构建新版本并增加第三方模
- 92.1K小星星,一款开源免费的远程桌面,让你告别付费远程控制!
- Go 人脸识别教程_piwigo人脸识别
- 安卓手机安装Termux——搭建移动服务器
- ubuntu 安装开发环境(c/c++ 15)_ubuntu安装c++编译器
- Rust开发环境搭建指南:从安装到镜像配置的零坑实践
- Windows系统安装VirtualBox构造本地Linux开发环境
- 标签列表
-
- cmd/c (90)
- c++中::是什么意思 (84)
- 标签用于 (71)
- 主键只能有一个吗 (77)
- c#console.writeline不显示 (95)
- pythoncase语句 (88)
- es6includes (74)
- sqlset (76)
- apt-getinstall-y (100)
- node_modules怎么生成 (87)
- chromepost (71)
- flexdirection (73)
- c++int转char (80)
- mysqlany_value (79)
- static函数和普通函数 (84)
- el-date-picker开始日期早于结束日期 (76)
- js判断是否是json字符串 (75)
- c语言min函数头文件 (77)
- asynccallback (87)
- localstorage.removeitem (77)
- vector线程安全吗 (73)
- java (73)
- js数组插入 (83)
- mac安装java (72)
- 无效的列索引 (74)
