大型共享状态的 scala/akka/stm 设计？

Question

我是 Scala 和 Akka 的新手，正在考虑使用它来解决问题。假设我有一个计算引擎（搜索解决方案）。我想通过为每个节点上的每个 cpu 提供自己的引擎实例来并行化跨 cpu 和跨节点的搜索。

引擎输入由少量标量输入和一个非常大的哈希表组成。每个引擎实例将使用其标量输入对哈希表进行一些小的本地更改，计算一个优点，然后丢弃它的更改（它们不需要被任何其他引擎实例提交/看到）。善值将返回给将在结果中进行选择的某个协调器。

我正在阅读一些关于 STM TransactionalMap 作为共享状态工具的信息。这看起来很理想，但我真的没有看到任何将它用作共享状态的完整示例。

问题：

• actor/stm 模型似乎适合这个问题吗？
• 您能举一个具体的例子来说明如何分配共享状态吗？ （是 Ref[TransactionalMap[,]] 作为消息吗？
• 在一个节点内分布共享状态与跨不同节点分布有什么不同吗？

求知的心，

艾伦

Answer 1

在处理共享内存方面，STM 听起来并不适合这里，因为您不希望引擎实例中所做的更改提交到哈希表的共享副本。

相反，immutable HashMap 可能更合适。映射中未更改的元素可以由引擎实例共享，只有每个映射中的差异会占用额外的内存空间。

actor 模型非常适合您想要做的事情。为您想要的每个引擎实例设置一个参与者，并向其传递带有标量值和哈希图的消息。然后让它将结果返回给协调器。