Akka调度器中嵌套Futures为何串行执行？

这个问题我之前在项目里踩过坑，其实核心是Akka Dispatcher的配置和线程模型特性导致的，咱们来理清楚：

为什么会出现串行执行的情况？ #

主要有两个常见原因：

• Dispatcher线程池并行度限制：如果你使用的Dispatcher（不管是默认的还是自定义配置的）线程池并行度设置过低，比如parallelism-min和parallelism-max都设为1，那所有提交到这个Dispatcher的任务（包括你启动的Futures）都会在同一个线程里排队执行，自然就是串行的。而ExecutionContext.Implicits.global是JVM提供的通用线程池，默认并行度等于CPU核心数，所以能并行处理任务。
• 误用PinnedDispatcher：如果你的Actor绑定的是PinnedDispatcher，这种Dispatcher是专门为单个Actor分配一个独立线程的，线程池大小固定为1。用它作为ExecutionContext启动Futures的话，所有Futures都会挤在这唯一的线程里，必然串行执行。

解决办法 #

针对不同的原因，我们可以对应调整：

1. 修改Dispatcher的并行度配置 #

在你的Akka配置文件（比如application.conf）里，给Dispatcher设置合理的并行参数。比如自定义一个适合后台任务的Dispatcher：

background-task-dispatcher {
  type = Dispatcher
  executor = "fork-join-executor"
  fork-join-executor {
    parallelism-min = 4          # 最小线程数
    parallelism-factor = 2.0     # 基于CPU核心数的倍数
    parallelism-max = 8          # 最大线程数
  }
  throughput = 100               # 每个线程处理多少任务后切换
}

然后在Actor里获取这个Dispatcher作为ExecutionContext：

// 在Actor中获取自定义Dispatcher
implicit val ec: ExecutionContextExecutor = context.system.dispatchers.lookup("background-task-dispatcher")

// 现在启动的Futures会并行执行
Future { doWork() }
Future { doWork() }

2. 避免用Actor的Dispatcher处理耗时任务 #

Actor的Dispatcher主要是用来处理Actor的消息投递和消息处理的，如果你的Futures是耗时的IO任务或者计算密集型任务，最好单独配置一个Dispatcher来处理，避免占用Actor的消息处理线程，导致Actor响应延迟。

3. 检查并替换PinnedDispatcher #

如果你的Actor用的是PinnedDispatcher，而你需要并行执行Futures，就把Dispatcher类型换成普通的Dispatcher，并调整线程池参数。

注意事项 #

• 不要随意用context.getDispatcher来启动大量耗时Futures，这会挤占Actor消息处理的资源，影响Actor的吞吐量和响应性。
• ExecutionContext.Implicits.global虽然方便，但它是全局共享的线程池，在Akka应用中推荐使用自定义Dispatcher来隔离不同类型的任务，避免全局资源竞争。

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