1

我正在向我的 akka.net 配置添加一个固定调度程序,因为我读到这将及时向我的演员发送消息,但是当我遵循 akka 配置时,我想出了这个

 using (_actorSystem = ActorSystem.Create("SchedulerAutoAction"))
            {
                var props = Props.Create<TaskSchedulerAktor>().WithDispatcher("pinned-dispatcher"); // handle the mailbox timely
                _actorRef = _actorSystem.ActorOf(props, "TaskSchedulerAutoActionActor");
            }

因为我想基于固定调度程序运行它,但目前我在终端中收到此错误

Unhandled Exception: Akka.Configuration.ConfigurationException: Dispatcher [pinned-dispatcher] not configured for path akka://SchedulerAutoAction/user/TaskSchedulerAutoActionActor
   at Akka.Actor.LocalActorRefProvider.ActorOf(ActorSystemImpl system, Props props, IInternalActorRef supervisor, ActorPath path, Boolean systemService, Deploy deploy, Boolean lookupDeploy, Boolean async)

有人使用调度程序并正确配置它吗?您能建议对我的代码进行任何改进吗?请告诉我

4

1 回答 1

0

您作为调度程序标识符传递的字符串参数实际上是您的参与者系统配置中的 HOCON 路径:对于PinnedDispatcher,该路径可以是akka.io.pinned-dispatcher

PS:请记住,您可以创建自己的固定设置 - 详细信息在我上面链接的文档中。

于 2019-07-10T04:30:34.603 回答