我是Scala和Akka的新手,正在考虑用它来解决问题.假设我有一个计算引擎(搜索解决方案).我想通过为每个节点上的每个cpu提供自己的引擎实例来跨cpus和跨节点并行化搜索.
引擎输入由少量标量输入和非常大的哈希表组成.每个引擎实例将使用其标量输入对哈希表进行一些小的本地更改,计算好,然后丢弃其更改(它们不需要由任何其他引擎实例提交/查看).善意值将返回给将在结果中选择的某个协调员.
我正在阅读一些关于STM TransactionalMap作为共享状态的工具.这似乎是理想的,但我没有看到任何使用它作为共享状态的完整示例.
问题:
探究思想想知道,
艾伦