scala - 如何管理 Akka 使用的核心数？

Question

我正在使用 scala 和 akka actor，但还没有找到一种方法来管理处理器内核来处理并行级别，这可以使用 akka 吗？还是对程序员透明？

Answer 1

我不知道您在“管理处理器核心”下的确切含义，所以我假设您想询问是否可以在 Akka 中控制执行线程。 直接 控制(即用 Thread.start() 生成它们并使用它们进行消息处理是不可能的，但 Akka 在线程管理配置方面仍然非常灵活。

在最低层 Akka 使用 Dispatchers它将 actors 绑定(bind)到底层线程池。例如，Akka 中的默认执行器使用 ForkJoinPool用于所有消息处理。调度程序可以是 ActorSystem 的默认值，也可以在每个 actor 的基础上指定；这是 explained extensively在官方文档中。

所以你可以说 Akka 为程序员透明地管理线程，但如果你真的想调整它的行为，总是可以通过适当的配置来实现。