java - akka - 如何获得多个 Actor 的结果？

Question

我想知道是否有最佳实践可以向 2 个不同的参与者发送 2 条消息

并等待所有这些(当然得到结果)以便继续执行。

即:

send message to actor 1
send message to actor 2
List<results> = wait.all(actor1,actor2)

Answer 1

您可能正在寻找 ask pattern与 Future.sequence 或 for 结合使用:

import akka.pattern.ask

case object Request

implicit val timeout = Timeout(5 seconds) // needed for `?` below

// Ask your actors for a result
val f1 = actorA ? Request
val f2 = actorB ? Request
val f3 = actorC ? Request

// for-comprehension
(for {
    x <- f1
    s <- f2
    d <- f3
} yield (f1, f2, f3)).map {
    case (r1, r2, r3) =>
        //Do your stuff with the results
}

// Future.sequence
Future.sequence(f1, f2, f3).map {
    case (r1, r2, r3) =>
        //Do your stuff with the results
}