同期アッカの俳優のベストプラクティス

Question

私は、主要なタスク

俳優Aを完了する必要があり、次の要件

を持っています。メッセージは、それがために俳優のBに渡し「特別」である場合には、主要なタスクを実行します処理し、タスク アクターBを終了：主要なタスクのために特別な論理タスクを実行し、AとBは一緒にこの

実装

public static class ActorA extends UntypedActor { 


    public void onReceive(Object message) { 
    if (message instanceof Work) { 
    // if message is special 
ActorRef actorB = this.getContext().actorOf(Props.create(ActorB.class,)); 
       actorB.tell(new specialTask(message.property), getSelf()); 

    } else { 
     unhandled(message); 
    } 
    } 
} 

完了

俳優のB

public static class ActorB extends UntypedActor { 


     public void onReceive(Object message) { 
     if (message instanceof specialTask) { 
     //do special task using the message that does not change the state of the message 

     } else { 
      unhandled(message); 
     } 
     } 
    } 

ActorAは俳優Bsがタスクで完了を依存しません。しかし、完成したばかりの俳優BからAに渡すメッセージがなければならないかどうかはわかりません。これは正しいアプローチですか？

Answer 1

私が理解できる限り、アクターBを使用してAで計算すべきでないものを計算したいだけです。この場合、AがBによって作成された結果に依存しない場合、計算が完了したらBからAにメッセージを送る必要があります。 Bの計算結果（ディスクへの書き込み、別のサービスへのポストなど）で、あなたが望むものを何でもできます。

アクターBのメールボックスをAからのメッセージでオーバーフローさせないために、Work PullingまたはReactive StreamというAkkaパターンを使用することをお勧めします。主な考え方は、アクターBにタスクを要求することです。

BがI/O /重い作業/ブロックを行う場合は、このアクターを分離して実行することを強くお勧めします。dispatcherそうしないと、システム全体がシャットダウンされる可能性があります。