gpt4 book ai didi

用于大型共享状态的 scala/akka/stm 设计?

转载 作者:行者123 更新时间:2023-12-04 16:01:17 25 4
gpt4 key购买 nike

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

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

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

问题:

  • actor/stm 模型看起来适合这个问题吗?
  • 你能展示一个如何分配共享状态的具体例子吗? (是 Ref[TransactionalMap[,]] 作为消息吗?
  • 与跨不同节点相比,在节点内分配共享状态有什么不同吗?

  • 好奇心想知道,

    艾伦

    最佳答案

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

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

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

    关于用于大型共享状态的 scala/akka/stm 设计?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/6913902/

    25 4 0
    Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
    广告合作:1813099741@qq.com 6ren.com