Akka：メールボックスを埋める対俳優の産卵

Question

（1台のマシン上で）長時間実行する計算を同時に実行したい場合は、Akkaのアクターが役立ちます。

1つのアプローチは、各作業ごとに新しいアクタをスポーンすることです。何かのように

while(true) { 
    val actor = system.actorOf(Props[ProcessingActor]) 
    (actor ? msg).map { 
     ... 
     system.stop(actor) 
    } 
} 

2番目のアイデアは、ルータの背後にある設定された数のアクターを設定することです。すべてのメッセージをルータに送信します。

システムがオーバーロードされている（受信したメッセージの速度が処理速度よりも高い）方が良いでしょうか？

どれが長く続きますか？そして、どちらも最終的にOOMErrorでシステムを爆破するだろうか？

Answer 1

各タスクに新しいActorを作成する前に、Futureを使用することもできます。それは本当にあなたが達成したいことにかかっています。メモリー使用量を最小限に抑えて多くの作業を行うには、アクター/ルーターのアプローチを使用する必要があります。各タスクはFutureとPromiseの新しいインスタンスを作成するので、先物はより高価です。しかし、それはあなたのユースケースに大きく依存します。私は本当にそれらの必要がないときに多くの俳優を作成しません。特にsystem.actorOfは常に新しいエラーカーネルを作成します。