如何解决是否可以将演员生成到流中?
所以我使用 Akka Typed,并希望将每个消息的 actor 生成到某个流中,根据文档似乎不可能:
- 警告:该方法不是线程安全的,不能从普通actor消息处理线程以外的线程访问,例如[[scala.concurrent.Future]]回调。
def spawn[U](behavior: Behavior[U],name: String,props: Props = Props.empty): ActorRef[U]
示例:
Behaviors.receiveMessage {
case StartConsume =>
context.log.info("Starting consume messages")
val source: Source[Int,NotUsed] = Source(1 to 10)
source.runForeach(x => context.spawn(Test(x),"Test"))
Behaviors.same
}
还有其他方法可以做到这一点吗?
解决方法
由于流将具体化为不同的actor,因此几乎可以肯定您无法关闭流中的ActorContext
(如果它恰好与上次运行的封闭actor在同一线程中执行,它不会爆炸),例如用于产卵。
作为替代:
-
如果您不特别关心生成的 actor 是该 actor 的子代(例如,在经典中,您将使用
system.actorOf
),您可以拥有守护 actor(具有产生ActorSystem
的行为产生演员:您可以推出自己的协议来执行此类产生,也可以让该监护人实现SpawnProtocol
。然后,您可以向context.system
发送适当的消息,但请注意,您需要使用context.system.unsafeUpcast
来使用您正在使用的协议。由于您应该控制监护人的协议,因此不太可能失败,但编译器不会真正帮助您。 -
如果您确实希望生成的 actor 成为子级,并且您还希望生成异步,那么实现这一点的最佳方法可能是通过导致仅生成 actor 的内部消息。然后在流中,您只需将这些消息发送给自己。
-
如果您不希望生成是异步的(应该注意的是,在流中生成它们的方法是),那么只需在消息处理线程中调用
spawn
而不是在一个流中。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。