如何檢測Akka演員何時完成？

Question

我試圖實現一個簡單的應用程序，我將不同的任務分配給Akka actors並讓他們獨立計算結果。問題是如何檢測何時他們全部已完成分配的作業（成功或失敗計數），因爲我需要從中獲得計算結果。典型的方法是什麼？

我嘗試使用system.shutdown（）等待所有actor都完成，但過去這個命令actors已經被終止，並且不響應任何需要的消息來檢索計算結果。

我想過的另一件事是從工人演員向他們的父母發送像JobCompleted消息。然後，我可以計算出我返回的這種類型的消息的數量，如果計數等於產生的工人演員，我們知道他們都已完成。雖然我不知道當演員發生失敗時會發生什麼。而且這種方法似乎太笨重了。

Answer 1

可能的重複：

Knowing when akka actors are finished

Akka tracking when the actors finished

---

最簡單的開箱即用的方式：用問格局，等待所有返回期貨。無論是在爲塊或通過Future.sequence （有關詳細信息，請參閱官方文檔）

另外，如果你需要終止的權利你的任務完成後 - 有許多不同的方法。例如，請參見http://letitcrash.com/post/30165507578/shutdown-patterns-in-akka-2

Answer 2

當您創建「作業」並將它們發送給工作人員時，您可以使用詢問模式創建結果的未來。

這看起來是這樣的：

val myActorRef = system.actorOf(Props(classOf[WorkerActor]), "worker") 

val result = (myActorRef ? SomeComputationMessage()).mapTo[Result] 

如果演員將其結果返回給調用者與sender ! Result()那麼這個問格局將返回一個未來的結果

由於這些都是期貨結果，可以映射在他們，與他們適當的工作基礎上成功/失敗

http://doc.akka.io/api/akka/2.0/akka/pattern/package.html

Answer 3

我會有一個協調角色，派生工人，然後發送每條消息指定它要做的工作，爲每個工人建立一個持有ActorRefs的集合。當在協調器中接收到一個JobCompleted（或者如果合適的話，JobFailed）消息時，累積結果並從該集合中刪除該消息的發送者（即Worker的ActorRef）。當該集合爲空時，所有工作人員都已完成。工作人員自己可以致電context.stop(self)，一旦他們發送了他們的信息，就可以自行終止。

進一步的語義將取決於具體的工作。例如，協調員可以設置回自己的預定呼叫（例如，呼叫context.system.scheduler.schedule(someDelay, someDelay, self, ResendWorkOrders)將每個someDelay間隔發送一次ResendWorkOrders消息給自己。當它接到這個呼叫時，它可以將工作請求重新發送給集合中剩下的每個工作人員（或者甚至重新生成）。當設置爲空（所有工人已經完成），調度可以取消（調用調度返回Cancellable）。例如，這可以處理可能無法向工作人員傳遞消息的情況（例如在分佈式系統中），或者工作人員可能在未答覆協調員的情況下出現故障或出錯的情況。