是否可以将演员生成到流中？

问题描述

所以我使用 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 而不是在一个流中。

akka akka-typed scala