我需要启动 Akka (2.0) 演员系统,发送一些消息,然后等待它完成繁重的工作。在那之后,我需要做一些与那些演员无关的事情。
我试图等待所有演员停止使用以下代码:
val system = new ActorSystem("parallelRunners")
val master = system.actorOf(Props[Master])
master ! Start
system.awaitTermination // <-- hangs here
所有演员都通过self ! PoisonPill
. 我究竟做错了什么?