Akka调度程序线程创建

Question

但没有。在应用程序中创建的dispatcher线程使我在优化dispatcher配置时束手无策。每次重新启动应用程序时，我都看到创建了不同数量的dispatcher线程（每次启动应用程序后，我都通过线程转储检查这一点）。

甚至线程数也不等于我在Parallelism-min中定义的线程数。由于这个低线程数，我的应用程序的处理速度非常慢。一查号码。通过下面的代码：

GetRuntime（）.AvailableProcessors（）；

consumer-dispatcher {
  type = "Dispatcher"

  executor = "fork-join-executor"

  fork-join-executor {
    parallelism-min = 500
    parallelism-factor = 20.0
    parallelism-max = 1000
  }

  shutdown-timeout = 1s

  throughput = 1
}

我可以知道akka将在什么基础上在内部创建调度线程，以及我如何增加我的调度线程数来增加参与者的并行处理吗？

Answer 1

X-来自discuss.lightbend.com的帖子

首先让我直接回答问题。

fork-join-executor将由java.util.concurrent.forkjoinpool池支持，其并行度设置为调度器配置中隐含的并行度。（并行度-因子*处理器，但不大于最大或小于最小）。所以，在你的情况下，800。