Absender in einer Zukunft

Question

Ich habe einen Akteur, der beim Empfang einer Nachricht das Dateisystem nach einer Datei durchsucht und den vollständigen Pfad der Datei zurückgibt.

def receive ={ 
case s:String => { 

    val f = future{ 
     val ans = search(s) 
     println("Input Request: "+s+" output:"+ans+" "+sender.path) 
    } 
    f.onComplete{ 
    case Success(x) => sender ! x 
    case Failure(y) => println("Could not complete it") 
    } 

} 

Aber ich habe festgestellt, dass es die Nachricht an akka://FileSystem/deadLetters und nicht die sender zurück:

es asynchron zu halten, habe ich getan. Dokumentation sagt das:

Nur gültig innerhalb des Schauspielers selbst, also schließen Sie nicht darüber und * veröffentlichen Sie es zu anderen Themen!

Also heißt es, ich muss es unbedingt synchron halten? Gibt es einen anderen Weg?

Answer 1

Sie sind einen sehr häufigen Fehler von „closing über veränderbaren Zustand“ zu machen. Die Schließung, die Sie an onComplete übergeben, macht keine Kopie von this.sender, also wenn Ihre onComplete aufgerufen wird, senden Sie die Nachricht an was auch immer this.sender zeigt auf, zu dem Zeitpunkt, zu dem es zeigte, wenn Sie die Schließung erstellt.

Sie können dieses Problem vermeiden, indem Sie Ihre eigene lokale, unveränderliche Kopie des aktuellen Inhalts von this.sender und Referenz Schaffung dieses Wert in der Schließung:

val origSender = sender 
f.onComplete { 
    case Successs(x) => origSender ! x 
    ... 
} 

Answer 2

import akka.pattern.pipe 

Macht den Trick. Doing:

val reply = sender 
future { 
    val ans = searchAndCache(s) 
    println("Input Request: "+s+" output:"+ans+" "+reply.path) 
    ans 
} pipeTo reply 

Antworten zurück an den Absender