scala - 如何为 futures、并行集合和 akka 创建共享线程池/executioncontext

Question

我想在我的应用程序中定义 2 个线程池。一个 fork-join 和一个线程池执行器。此外，每个池应该能够由 Akka 参与者、Scala future 和 Scala 并行集合共享。

对于 future ，scala 需要范围内的执行上下文，并且可以通过以下方式之一创建:

implicit val ec = ExecutionContext.global //want to avoid this
import scala.concurrent.ExecutionContext.Implicits.global //want to avoid this
implicit val ec = ExecutionContext.fromExecutor(Executors.newFixedThreadPool(64))
implicit val ec = ExecutionContext.fromExecutor(Executors.newForkJoinThreadPool(64))

对于并行收集，你必须像这样修改 TaskSupport

val forkJoinPool = new java.util.concurrent.ForkJoinPool(64)
parArray.tasksupport = new ForkJoinTaskSupport(forkJoinPool)

有了上面的内容，我唯一的选择是在我的应用程序中全局定义 val forkJoinPool = new java.util.concurrent.ForkJoinPool(64) 并将其用于两者。

但是，我不知道如何为 Akka Actor 使用同一个池。 对于 Akka，我至少看到了以下两种自定义池的方法。

val actorSysterm = ActorSystem.create("hello-system", config.getConfig("my-dispatcher”)) 
implicit val executionContext = actorSysterm.dispatcher

implicit val system = ActorSystem()
implicit val executionContext = actorSysterm.dispatchers.lookup("my-dispatcher")

这是基于配置文件。

my-dispatcher {
  type = Dispatcher
  executor = "fork-join-executor"
  fork-join-executor {
    parallelism-min = 8
    parallelism-factor = 2.0
    parallelism-max = 64
  }
  throughput = 100
}
blocking-io-dispatcher {
  type = Dispatcher
  executor = "thread-pool-executor"
  thread-pool-executor {
    fixed-pool-size = 32
  }
  throughput = 1
}

我更喜欢 Akka 创建 ExecutionContext 因为现在我可以在 hocon(json) 文件中配置我的池并且也可以在 play 框架应用程序中使用它。我可以将它与 Scala Futures 一起使用，但现在如何将它与 Scala Parallel 集合一起使用呢？有没有办法从 ExecutionContext 访问底层池，这样我就可以用它来初始化并行集合的 TaskSupport？

Answer 1

我之前忽略了并行收集使用的 TaskSupport 的另一种实现。这样我就可以使用与 Future 和 ActorSystem 相同的 executionContext。

pc.tasksupport = new ExecutionContextTaskSupport(executionContext)