Blockiert dieser Scala-Actor beim Erstellen eines neuen Actors in einem Handler?

Question

Ich habe folgende Stück Code:

actor { 
    loop { 
    react { 
     case SomeEvent => 
     //I want to submit a piece of work to a queue and then send a response 
     //when that is finished. However, I don't want *this* actor to block 
     val params = "Some args" 
     val f: Future[Any] = myQueue.submitWork(params); 
     actor { 
      //await here 
      val response = f.get 
      publisher ! response 
     } 

    } 
    } 
} 

Wie ich es verstanden, die äußere Darsteller nicht auf f.get blockieren, weil die tatsächlich von einem separaten Schauspieler durchgeführt wird (der einen im Inneren des SomeEvent Handler erstellt).

Ist das korrekt?

Answer 1

Ja, das ist richtig. Dein äußerer Schauspieler wird einfach einen Schauspieler erschaffen und aussetzen (auf seine nächste Nachricht warten). Sei jedoch sehr vorsichtig mit dieser Art von Dingen. Der innere Akteur wird automatisch auf dem Scheduler gestartet, um von einem Thread behandelt zu werden. Dieser Thread wird auf diesem Future blockieren (das sieht für mich wie eine java.util.concurrent.Future aus). Wenn Sie dies oft genug tun, können Sie auf Probleme stoßen, bei denen alle verfügbaren Threads auf Futures blockieren. Ein Akteur ist im Grunde eine Arbeitswarteschlange, daher sollten Sie stattdessen diese Semantik verwenden.

Hier ist eine Version Ihres Codes, mit der Scalaz actors library. Diese Bibliothek ist viel einfacher und leichter zu verstehen als die Standard-Scala-Akteure (die Quelle ist buchstäblich eineinhalb Seiten). Es führt auch zu vielem Prüfcode:

actor {(e: SomeEvent) => promise { ... } to publisher } 

Diese Version ist vollständig nicht blockierend.