如何解决Akka自定义调度程序查找失败
我仅使用akka来获取调度程序并为ExecutionContextExecutor做底层设计。当我发现它的调度程序配置比Java容易得多时。我没有使用任何akka演员。仅尝试查找在application.conf
中定义的自定义调度程序,然后在我的scala应用中将其与将来的和并行的集合一起使用。
psuedo application.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
解决方法
您可以在application.conf中尝试吗(请注意配置位于顶层而不是嵌套在akka中)
my-executor {
...
}
在您的应用程序代码中:
implicit val actorSysterm = ActorSystem()
actorSysterm.dispatchers.lookup("my-executor")
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。