这个问题不言自明。
目前,我的webapp正在startup中创建actor系统,并使用 SpawnProtocol
. 此外,启动还可以在启动期间向这些参与者发送一些消息。
当创建顶级演员时,akka返回一个 CompletionStage
等待演员被创建的。
对于这种在角色生成期间接受消息的场景,最佳的设计模式是什么?我应该让启动等待参与者生成完成,还是隐藏发送的消息并让线程继续?如果存储,那么请发送一些例子存储技术是线程安全和性能
注意,我在应用程序中使用的是akka类型、java和spring
1条答案
按热度按时间pgky5nke1#
基本思想是
CompletionStage
api链接调用以引导应用程序。既然你对你的引导不太具体,我想你需要一个
ActorRef
启动你的应用程序。在上面的片段中spawnActorRef()
这就是所谓的SpawnProtocol
返回CompletionStage
你的ActorRef
然后你可以使用thenApply
一旦ref可用,就链接一个操作,并使用它传递给引导代码的其余部分。