无国籍阿卡演员

Question

我只是从阿卡开始，我试图将一些混乱的功能分成更容易管理的部分，每个部分都由不同的演员执行。

我的任务似乎正是适合演员模式的。我有一个对象树，它们保存在数据库中。每个节点都有一些属性；让我们只关注一个，称之为财富。孩子的财富取决于父母的财富。当计算节点上的财富时，这应该会在子节点上触发类似的计算。我想收集节点的所有更新实例，并同时将它们保存在数据库中。

这似乎很简单：一个参与者只需执行计算，然后为当前节点的每个子节点启动另一个参与者。当所有子节点发回包含计算结果的消息时，参与者收集它们，添加当前节点，并向其上方的参与者发送消息。

问题是，我不知道有什么方法可以确保一个人收到了所有孩子的信息。一个简单的方法是使用计数器，并在收到来自孩子的消息时增加计数器。

但是，如果系统的两个独立部分需要执行这样的计算，并且重复使用同一个参与者，会发生什么呢？演员将产生两倍的孩子，而且计数将不再可靠。我需要的是确保不从外部系统重用相同的参与者，但每次触发计算时都会生成新的参与者。

这可能吗？如果没有，阿克卡是否有某种自动机制来确保每个孩子都完成了任务？

我只是在不适合这里的情况下使用演员模型吗？从本质上说，我所做的只是函数本身——参与者本身是无状态的，但它们允许我简化和并行计算。

Answer 1

你描述事物的方式，我认为你真正想要的是一个递归函数，它返回一个未来[Tree[NodeWalth]]，函数每次被调用时都会产生一个未来，它会为层次结构中的每个子级调用自己，在函数的末尾，它会将这些调用的未来组合成一个未来[Result]。当递归函数终止并返回Future[Tree[nodeWalth]]时，您可以将其与另一个Future组合，该Future更新数据库。看看这里关于未来的Akka文档。并特别注意“撰写期货”一节。

期货的组合应该允许你避免这种状态，并且很容易实现。

另一种选择是使用actors和futures，并对子actors使用ask模式，将生成的futures组合成一个futures，然后返回给发送方（父actor）。这本质上是同一件事，只是与演员纠缠在一起。如果您出于其他原因已经将节点表示为参与者，我可能只会走这条路。