Ausführungskontext für Futures in Actors

Question

Ich habe einen Akteur, und auf irgendeine Nachricht, die ich eine Methode laufen lasse, die Zukunft zurückgibt.

def receive: Receive = { 

    case SimpleMessge() => 
     val futData:Future[Int] = ... 
     futData.map { data => 
      ... 
     } 
} 

Ist es möglich, den tatsächlichen Kontext zu übergeben, um auf diese Daten zu warten? Oder Await ist das Beste, was ich tun kann, wenn ich diese Daten in SimpleMessage brauche?

Answer 1

Wenn Sie wirklich warten müssen für die Zukunft vor der Verarbeitung die nächste Nachricht zu vervollständigen, können Sie so etwas wie dies versuchen:

object SimpleMessageHandler{ 
    case class SimpleMessage() 
    case class FinishSimpleMessage(i:Int) 
} 

class SimpleMessageHandler extends Actor with Stash{ 
    import SimpleMessageHandler._ 
    import context._ 
    import akka.pattern.pipe 

    def receive = waitingForMessage 
    def waitingForMessage: Receive = { 

    case SimpleMessage() => 
     val futData:Future[Int] = ... 
     futData.map(FinishSimpleMessage(_)) pipeTo self 
     context.become(waitingToFinish(sender)) 
    } 

    def waitingToFinish(originalSender:ActorRef):Receive = { 
    case SimpleMessage() => stash() 

    case FinishSimpleMessage(i) => 
     //Do whatever you need to do to finish here 
     ... 
     unstashAll() 
     context.become(waitingForMessage) 

    case Status.Failure(ex) => 
     //log error here 
     unstashAll() 
     context.become(waitingForMessage)  
    } 
} 

Bei diesem Ansatz verarbeiten wir eine SimpleMessage und dann Logik wechseln Handhabung zu verstauen alle nachfolgenden SimpleMessage s erhalten, bis wir ein Ergebnis aus der Zukunft bekommen. Wenn wir ein Ergebnis bekommen, Versagen oder nicht, stürzen wir alle anderen SimpleMessage s ab, die wir erhalten haben, während wir auf die Zukunft warten, und gehen auf unseren fröhlichen Weg.

Dieser Aktor schaltet einfach zwischen zwei Zuständen hin- und her und ermöglicht es Ihnen, nur eine SimpleMessage gleichzeitig zu verarbeiten, ohne die Zukunft zu blockieren.