akka类型在产卵期间发送消息

eiee3dmh  于 2021-07-16  发布在  Java
关注(0)|答案(1)|浏览(277)

这个问题不言自明。
目前,我的webapp正在startup中创建actor系统,并使用 SpawnProtocol . 此外,启动还可以在启动期间向这些参与者发送一些消息。
当创建顶级演员时,akka返回一个 CompletionStage 等待演员被创建的。
对于这种在角色生成期间接受消息的场景,最佳的设计模式是什么?我应该让启动等待参与者生成完成,还是隐藏发送的消息并让线程继续?如果存储,那么请发送一些例子存储技术是线程安全和性能
注意,我在应用程序中使用的是akka类型、java和spring

pgky5nke

pgky5nke1#

基本思想是 CompletionStage api链接调用以引导应用程序。

CompletionStage<ActorRef<Stuff>> actorRefPromise = spawnActorRef();

actorRefPromise.thenApply(actorRef -> bootStrapApp(actorRef))

既然你对你的引导不太具体,我想你需要一个 ActorRef 启动你的应用程序。在上面的片段中 spawnActorRef() 这就是所谓的 SpawnProtocol 返回 CompletionStage 你的 ActorRef 然后你可以使用 thenApply 一旦ref可用,就链接一个操作,并使用它传递给引导代码的其余部分。

相关问题