- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
我有一个关于 Java 中的 CompletableFuture 的问题。我正在等待 CompletableFuture 完成,根据收到的结果,我想调用一个新任务并等待 CompletableFuture 完成或做一些不同的事情。我对我的解决方案不满意,因为有太多的回调并且阅读起来不一样。你能帮我改进我的代码吗?
final CompletableFuture<String> future = new CompletableFuture<>();
final ActorRef processCheckActor = actorSystem.actorOf(
springExtension.props("ProcessCheckActor"), "processCheckActor-" + new Random().nextInt());
final CompletableFuture<Object> checkResponse =
PatternsCS.ask(processCheckActor, new ProcessToCheckMessage(processId), TIMEOUT)
.toCompletableFuture();
checkResponse.thenAccept(obj -> {
final ProcessCheckResponseMessage msg = (ProcessCheckResponseMessage) obj;
if (msg.isCorrect()) {
final CompletableFuture<Object> response =
PatternsCS.ask(processSupervisorActor, new ProcessStartMessage(processId), TIMEOUT)
.toCompletableFuture();
response.thenAccept(obj2 -> {
future.complete("yes");
});
} else {
future.complete("no");
}
});
最佳答案
首先,你应该避免创建 CompletableFuture<Object>
.通用类型应该是您的函数返回的类型(在您的情况下为 CompletableFuture<ProcessCheckResponseMessage>
)。这样你就不需要 Actor 了。
我建议使用 thenApply
而不是 thenAccept
.这将为您创建第二个 CompletableFuture,这意味着您不再需要第一行中的声明。
最后,一般来说,对于多行 lambda,您应该三思而后行,绝对要避免嵌套的 lambda。您应该考虑为这些 lambda 表达式创建一个新方法。
关于Java CompletableFuture : Avoid callback hell,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40692698/
不同的编程语言使用不同的打包系统。 Java 的 Maven 采用各种不同的方法。对我来说似乎是最好的选择,因为它在不同版本的文件夹中维护不同版本的 jar 文件,因此,没有办法最终导致库的版本冲突。
这个问题已经有答案了: force browsers to get latest js and css files in asp.net application (23 个回答) 已关闭 7 年前。
我目前正在将带有一些回调 hell 的构建过程转换为 promise hell ( hell 很可能是因为我是 promises 的新手并且我对 Bluebird 缺乏经验)。我正在努力通过 .all
在我的一个项目中,我使用了一个动态加载包装器 DLL(导出 C 风格函数)的 Delphi 应用程序,后者又静态链接到一堆第 3 方 DLL。 它在我的测试机器上工作正常,但在我的客户计算机上它无法初
昨晚我试图放一个简单的教程来使用堆栈构建应用程序 - Spring(2.5)+ JPA(1.0)+ Hibernate(第一次下载,所以不知道使用哪个版本)。不幸的是,我不想使用 Maven,因为目标
class Badge(SafeDeleteModel): owner = models.ForeignKey(settings.AUTH_USER_MODEL,
为什么这个查询: SELECT "hello" = " hello", "hello" = "hello ", "hello" <> "hello ", "hello"
我目前正在尝试从公共(public) API 获取有关一个国家及其邻国的数据,以在我的 html 上呈现。 renderCountry( ) 是一个函数,用于在我的 html 上实现我将收到的数据。
我的背景是 Python,在 Python 中,您将所有事物都视为鸭子,并且无需定义类型。我最近开始使用 Dart 编写代码,现在我遇到了这些类型转换问题。 下面的代码有什么问题? appendCsv
这是我的目录结构: ├── src │ ├── helpers │ │ ├── __init__.py │ │ ├── foo.py │ │ └── bar.py │
关闭。这个问题是opinion-based .它目前不接受答案。 想改进这个问题?更新问题,以便 editing this post 提供事实和引用来回答它. 2年前关闭。 Improve this
我正在尝试在 Haskell 项目中包含特定版本的库。该库是住宿加早餐型的(用于 martix 操作),但我需要特定的 0.4.3 版本,该版本修复了乘法实现的错误。 所以,我的 stack.yaml
我偶尔会遇到一个问题,即为设备配置开发版本的应用程序。错误消息通常是“找不到此可执行文件的有效配置文件”。 我已遵循所有 Apple 说明:我拥有有效的开发证书,开发人员配置文件包含相关设备的设备 I
我正在开发具有少数不同项目的 asp.net 核心解决方案,每个项目都使用某个版本库的 3rd 方 NuGet 包。这些版本,例如1.0.0 和 2.0.0,有重大变化。另外,这个库是由另一个项目团队
我正在尝试为我制作的自定义组件制作一个包。它基于多个库,包括 Graphics32、GraphicEx 和 CCR.Exif。 我创建了一个Package项目,编写了包括其Register过程的单元,
在研究 NodeJS 中的“回调 hell ”时,我得到了很多推荐相同内容的网站。浅层函数、模块化,以及一些工具,如 Promise、异步和生成器。 从技术上讲,我知道什么是回调,也知道为什么在 No
我使用Python构建了一个AI应用程序,其中涉及大量的Python库。此时,我想在Docker容器中运行我的应用程序以使AI App成为服务。 关于依赖项,我有哪些选择,以便自动下载所有必需的库?
谁能提供 SecurityDriven.Inferno AesCtrCryptoTransfom 的使用示例类(class) ? 该库似乎很有前途,但我无法找到任何使用它的代码,并且提供的详细信息对我
我有一个需要重复执行的任务,因此我尝试为其编写一个函数。我的函数几乎完成了,除了一个缺陷:我无法将公式作为参数传递,除非它是字符串的形式。 library(lme4) library(lazyeval
关闭。这个问题需要多问focused 。目前不接受答案。 想要改进此问题吗?更新问题,使其仅关注一个问题 editing this post . 已关闭 7 年前。 Improve this ques
我是一名优秀的程序员,十分优秀!