Akka控制线程池线程

Question

可能是一个非常愚蠢的问题——

是否可以自定义 Akka/Scala actor 以便控制 actor 使用的线程？例如，您可以初始化要在线程池中使用的自己的线程集，或者以其他方式控制/修改线程吗？

Answer 1

在 Akka 中，线程池是通过 MessageDispatcher 实例进行管理的。您可以轻松地为参与者设置您想要的调度程序：

class MyActor( dispatcher: MessageDispatcher ) extends Actor {
  self.dispatcher = dispatcher
  ...
}

要提供您自己的调度程序，您可以扩展akka.dispatch.MessageDispatcher（请参阅现有调度程序实现的示例）。在这里你可以直接玩线程。

当然，将业务逻辑放入调度程序中是危险的，因为它可能会破坏参与者模型并增加并发错误的数量......

Answer 2

我试图自己理解它，但 Akka 中的人似乎不希望线程管理暴露在公众面前。

ThreadPoolConfig - 负责创建ExecutorService实例的类是一个案例类，其方法createExecutorService()声明为final！

  final def createExecutorService(threadFactory: ThreadFactory): ExecutorService = {
    flowHandler match {
      case Left(rejectHandler) ⇒
        val service = new ThreadPoolExecutor(...)
        service
      case Right(bounds) ⇒
        val service = new ThreadPoolExecutor(...)
        new BoundedExecutorDecorator(service, bounds)
    }
  }

因此，我没有看到提供自己的 ExecutorService 的简单方法。