Inkrementelle Verarbeitung in einem Akka-Schauspieler
Ich habe Schauspieler, die sehr langwierige und rechenintensive Arbeit leisten müssen, aber die Berechnung selbst kann inkrementell erfolgen. Während die vollständige Berechnung selbst Stunden in Anspruch nimmt, sind die Zwischenergebnisse tatsächlich äußerst nützlich, und ich möchte in der Lage sein, auf alle Anfragen von ihnen zu antworten. Dies ist der Pseudocode für das, was ich tun möchte:
var intermediateResult = ...
loop {
while (mailbox.isEmpty && computationNotFinished)
intermediateResult = computationStep(intermediateResult)
receive {
case GetCurrentResult => sender ! intermediateResult
...other messages...
}
}