为什么 actor 模块不支持并发邮箱?
why actor module not support concurrent mailbox?
刚接触akka,也是actor,不知为何找不到并发邮箱使用
因此,我必须定义一个调度 actor 发送给它的工作 actor.Many 次,我不关心数据的顺序,在这种情况下按顺序发送消息只需要时间。
我发现使用 Router props 创建 actor 是不错的选择:
val actorRef: ActorRef = context.actorOf(Props[MyActor]
.withRouter(RoundRobinPool(nrOfInstances = 4)), name = "myActor")
//or
context.actorOf(RoundRobinPool(5).props(Props[MyActor]), "myActor")
它将创建四个 actor 实例,但 return 一个 actorRef -- RoundRobinPool
处理并向这些 actor 发送消息。
刚接触akka,也是actor,不知为何找不到并发邮箱使用
因此,我必须定义一个调度 actor 发送给它的工作 actor.Many 次,我不关心数据的顺序,在这种情况下按顺序发送消息只需要时间。
我发现使用 Router props 创建 actor 是不错的选择:
val actorRef: ActorRef = context.actorOf(Props[MyActor]
.withRouter(RoundRobinPool(nrOfInstances = 4)), name = "myActor")
//or
context.actorOf(RoundRobinPool(5).props(Props[MyActor]), "myActor")
它将创建四个 actor 实例,但 return 一个 actorRef -- RoundRobinPool
处理并向这些 actor 发送消息。