Akka为何创建随Actor数增长的大量dispatcher？

两个核心使用错误直接导致dispatcher数量随Actor数线性增长，外加配置不合理放大了线程空转问题：

• 每创建一个Actor就新建一个ActorMaterializer实例
  ActorMaterializer是持有独立调度器、线程池的重量级组件，设计上要求按调度类型复用，不需要和Actor实例一一对应。你为数百个Actor分别创建独立的Materializer，自然会生成数百个对应的dispatcher实例。
• dispatcher配置路径与代码查找路径完全不匹配
  Akka自定义dispatcher的默认配置根节点是akka.actor，你代码里写的查找路径是akka.dispatchers.$dispatcherName，本身就不符合Akka的路径规则；再加上你贴的配置末尾多了一个多余的闭合花括号，说明你定义的dispatchers节点根本没有挂载到akka.actor下，Akka完全读不到你预定义的7个dispatcher。这种情况下每次传入不存在的dispatcher路径，Akka都会生成一个新的匿名dispatcher，不会做任何复用。
• 线程池配置不合理
  你给connector-actor-dispatcher、http-client-dispatcher-parser两个dispatcher设置了200的固定线程池大小，就算dispatcher正常复用，仅这两个就会生成400个常驻线程。你贴的线程栈里大量TIMED_WAITING的空转线程，就是thread-pool-executor创建的核心线程——这类线程默认不会被回收，哪怕没有任务也会一直驻留等待。非阻塞任务根本不需要这么大的线程数，CPU密集型场景线程数和CPU核数对齐即可，非阻塞IO场景最多设为CPU核数*2，多余线程只会空占内存。

1. 修正配置层级
   把所有自定义dispatcher配置移动到akka.actor节点下，删掉多余的闭合花括号，结构参考：

akka {
  actor {
    dispatchers {
      connector-actor-dispatcher {
        type = Dispatcher
        executor = "fork-join-executor" # 非阻塞任务优先用forkjoin，减少空转
        fork-join-executor {
          parallelism-min = 2
          parallelism-factor = 1.0
          parallelism-max = 16 # 按CPU核数调整，不要写200
        }
        throughput = 1
      }
      # 其余6个dispatcher按同样规则调整，全部放在这个节点下
      # 固定线程池的配置全部改掉，不要用200的固定值
    }
  }
}

2. 修正dispatcher查找路径
   初始化Materializer时直接传dispatcher名称即可，不需要加错误的前缀：

// 错误写法：.withDispatcher(s"akka.dispatchers.$dispatcherName")
// 正确写法
val mat = ActorMaterializer(ActorMaterializerSettings(system).withDispatcher(dispatcherName))(system)

3. 复用ActorMaterializer实例
   同一种dispatcher只需要创建一个全局的ActorMaterializer实例，所有用该调度器的Actor、流处理逻辑全部复用这一个实例，禁止为单个Actor单独创建Materializer。
4. 调整线程池类型
   非阻塞任务优先使用fork-join-executor，这类线程池会根据任务量动态伸缩线程数，不会像thread-pool-executor那样留大量核心线程空转。

内容的提问来源于stack exchange，提问作者yi1