我是演员的新手,我正在尝试了解如何正确链接演员。我已阅读文档的 Ask: Send-And-Receive-Future部分。
这是我现在的做法
case class Message1(text : String)
class RootActor extends Actor {
def receive: Actor.Receive = {
case Message1(message) => {
(context.actorOf(Props( new TestActor1)) ? message)(5.seconds) pipeTo sender
}
}
}
class TestActor1 extends Actor {
def receive: Actor.Receive = {
case message : String => {
sender ! (message + " TestActor1")
}
}
}
object Test {
def main(args: Array[String]) {
println("Start!")
implicit val system = ActorSystem()
val rootActor = system.actorOf(Props( new RootActor))
for (reply1 <- (rootActor ? Message1("Begin"))(5.seconds).mapTo[String])
println(reply1)
}
}
所以我手动中继回复。但是子演员的回复不应该自动冒泡到其父母吗?这是正确的做法吗?
另外我担心以手动方式冒泡我使用的回复ask
需要超时。但是,如果某个子角色需要比其他角色更多的时间来完成它的工作,但是当我向根角色发送消息时我受到一个超时值的限制,该怎么办?在我看来,在整个链中保持适当的超时非常麻烦。
我怎样才能简化它?