akka tutorialに従っています。基本的に、 a listener
、 a master
、およびいくつかworker
の s があります。
class Listener extends Actor {
def receive = {
case Report => // message from Master, print result, shutdown system
}
}
class Master extends Actor {
def receive = {
case Calculate => // ask Workers to calculate
case Result => // message from Workers, aggregate results.
// if all Workers have reported back, stop self and children,
// and send Report message to Listener
}
class Worker extends Actor {
def receive = {
case Calculate => // work, send result back to Master
}
}
Listener
私の質問は、どうすれば外の世界から結果を得ることができますか? Report
メッセージが であると仮定しますcase class Report(results: Int)
。