如何在不提供时间参数的情况下使用 Akka 未来？

Question

我有两个主要演员（主要工人，次要工人）-

1.main worker 将样本组划分为单个样本 2.sec 主要工作人员获取样本并进行处理。（使用子工作人员）

问题：我希望主要工作人员等待加载任何新样本组，直到旧样本组完成。并且处理每个样本组所花费的时间各不相同。在这种情况下如何使用期货？每个主要工作人员在完成样本组结束时发送样本组完成消息。

在时间限制未知的情况下，可以在这种情况下使用期货吗？我是futures新手，我搜索的大部分futures例子都在其中提到过。

Answer 1

这是一个不依赖于未来或时间的场景示例：

场景示例：

Actor1 拆分样本组并保留样本集合 在接收中，您可以从 Actor2 获取新样本的请求，并将其从当前样本集合中删除。 当样本集合为空时，您可以请求新的样本组。

Actor2 具有相同的收集机制来跟踪当前样本上已完成的工作，每次子工作人员完成一项任务时，将其从集合中删除。当集合为空时，向 Actor1 请求一个新样本

您可能希望在 Actor2 上安排一个超时，因此如果它没有消息超过一个时间间隔，那么您可以抛出错误或再次重试处理示例。