object Main extends App {
//val name: String = "Apka"
val system = ActorSystem()
val worker = system.actorOf(Props[Worker], name = "workerActor")
worker ! "test"
worker ! FetchUrl(new URL("http://google.com"))
println("test")
//Await.time
val stopped: Future[Boolean] = gracefulStop(worker, 15 seconds)
Await.result(stopped, 16 seconds)
system.shutdown()
}
我正在尝试使用sbt和~run选项测试scala应用程序,但是使用这种方法,系统在所有队列为空之前停止运行,而如果不使用它,我必须重新启动整个sbt。是否有一种方法可以在设定的时间段后或所有actor队列为空后停止actor系统?