免责声明:我只是使用akka来获取调度程序和底层ExecutionContextExecutor。我没有使用任何akka参与者。我查找配置文件application.conf
中定义的自定义调度程序,然后在我的scala应用程序中使用它来处理未来和并行集合。
虚拟应用程序.conf:
akka {
my-executor {
...
}
}
现在,我对akka docs中的以下行感到困惑:
查找调度程序implicit val executionContext = system.dispatchers.lookup("my-dispatcher")
https://doc.akka.io/docs/akka/2.5.24//dispatchers.html
它指的是什么system
(ActorSystem),它知道application.conf中定义的所有执行器配置,或者能够从中创建调度程序?
因为我试着跟随,但失败了:
implicit val actorSysterm = ActorSystem()
actorSysterm.dispatchers.lookup("akka.my-executor") //Error: akka.ConfigurationException: Dispatcher [akka.my-executor] not configured
1条答案
按热度按时间abithluo1#
你能在application.conf中尝试一下吗(注意配置是在顶层而不是嵌套在akka中)
在您的应用程序代码中: