Play Framework默认Dispatcher无法并行执行Futures问题咨询

这个问题我之前排查过类似的情况，核心原因是Play框架默认使用的执行上下文并不是你配置的akka.actor.default-dispatcher，同时你的Akka默认dispatcher配置可能没有真正生效，导致看起来完全无法并行。

1. Play与Akka默认Dispatcher的区别 #

Play框架为了适配Web应用的请求处理特性，自带了专属的默认Dispatcher配置节点：play.akka.actor.default-dispatcher。而你在common.conf里修改的是Akka核心的akka.actor.default-dispatcher——这两个是完全独立的配置项！

• 当你在Controller中注入implicit ec: ExecutionContext，或者调用as.dispatcher时，获取的其实是Play专属的那个Dispatcher，和你配置的Akka核心默认Dispatcher毫无关系。
• 即使你显式调用lookup("akka.actor.default-dispatcher")，这个Dispatcher的配置也可能被Play的默认设置覆盖了（比如Play启动时优先加载自身默认配置，导致你的并行度参数没生效），最终变成了低并行甚至单线程执行。

2. 先验证配置是否真正生效 #

你可以在代码里加一行日志，打印Dispatcher的实际配置，确认你的设置有没有被加载：

def testFutures(dispatcherId: String) = Action.async { implicit request =>
  val dispatcher = as.dispatchers.lookup(dispatcherId)
  // 打印实际生效的配置
  log.info(s"Dispatcher [$dispatcherId] 实际配置: ${dispatcher.settings.config.root().render()}")
  implicit val ec = dispatcher
  // 后续代码不变...
}

如果输出里的parallelism-min/parallelism-max不是你设置的4和8，那说明你的配置根本没被应用。

3. 针对性解决方案 #

方案一：修改Play专属的默认Dispatcher（推荐） #

如果你想让Controller默认使用高并行的执行上下文，直接修改Play的专属配置节点，而不是Akka核心的：

# 在common.conf或application.conf中添加
play.akka.actor.default-dispatcher {
  executor = "fork-join-executor"
  fork-join-executor {
    parallelism-min = 4
    parallelism-factor = 2.0
    parallelism-max = 8
  }
}

这样无论是注入的ec还是as.dispatcher，都会使用你想要的并行配置。

方案二：强制让Akka核心默认Dispatcher生效 #

如果你确实想使用akka.actor.default-dispatcher，需要确保你的配置能覆盖Play的默认设置：

1. 确保common.conf被正确包含到application.conf中（开头加include "common.conf"）
2. 在配置中使用override关键字强制覆盖默认值：

akka.actor.default-dispatcher {
  executor = "fork-join-executor" override
  fork-join-executor {
    parallelism-min = 4 override
    parallelism-factor = 2.0 override
    parallelism-max = 8 override
  }
}

方案三：直接在代码中指定使用自定义Dispatcher #

既然你的akka.my-dispatcher能正常工作，也可以在Controller中直接注入这个Dispatcher，或者默认使用它：

@Singleton
class HomeController @Inject()(
  cc: ControllerComponents, 
  as: ActorSystem,
  @NamedDispatcher("akka.my-dispatcher") implicit val customEc: ExecutionContext
) extends AbstractController(cc) {
  // 后续代码中直接使用customEc即可，无需再lookup
}

4. 额外注意事项 #

• 修改配置后一定要重启应用，Play的配置是启动时加载的，运行时不会自动刷新。
• 避免在Web请求处理中使用Thread.sleep（虽然你是测试用），实际场景中应该用非阻塞的延迟API，比如akka.pattern.after。

内容的提问来源于stack exchange，提问作者mmendez.semantic