6

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

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

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

问题：

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

求知之心，

艾伦

4

1 回答 1

1

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

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

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

于 2011-08-30T18:31:14.893 回答