为 Akka 中的所有用户 Actor 使用自定义调度程序以避免系统 Actor 的线程饥饿

Question

问题是关于 Akka 2.5.x 中的调度程序配置。

我想避免由于系统消息未传递而可能导致节点被隔离的线程饥饿问题。为了实现这一点，我想创建与默认调度程序配置完全相同的单独调度程序。

我已经定义了名为my-dispatcher {...} 的自定义调度程序配置。我可以使用以下内容让 Akka 将此调度程序用于所有用户的演员吗？

akka.actor.deployment {
    "/**" { # <- should this work?
        dispatcher = my-dispatcher
...
}

想法来自文档中的以下示例：

# all direct children of '/user/actorC' have a dedicated dispatcher 
"/actorC/*" {
    dispatcher = my-dispatcher
}

因此，如果我将actorC 替换为**，它将针对/user 下的所有参与者，我希望它能够工作。有人这样做吗？或者我需要寻找其他解决方案？

Answer 1

据我检查，您的方法有效，它会覆盖 user 路径下所有参与者的调度程序。

虽然配置默认调度程序的更传统方法只是覆盖akka.actor.default-dispatcher 下的配置条目（您只能覆盖其中的一些），例如：

akka {
  actor {
    default-dispatcher {
      fork-join-executor {
        parallelism-min = 2
      }
      throughput = 100
  }
}

如果您坚持在配置中使用不同路径定义的调度程序作为默认值，您可以用my-dispatcher 覆盖default-dispatcher 部分：

akka.actor.default-dispatcher = ${path.to.my-dispatcher}