scala - Akka.io: アクターあたりのスレッド数

Question

1,000 回の操作を非同期で実行する必要があるため、Akka を使用することにしました。Actor Ref Executor でワープし、ref に 1000 のメッセージを送信します。

次のことを確認するにはどうすればよいですか。

• 1,000 件のメッセージすべてが asnc 方式でディスパッチされます
• それぞれが個別の独立したスレッドを保持します (これは io の使用のための要件です)。

Answer 1

を使用して、PinnedDispatcherアクターごとに 1 つのスレッドを保証することができ、Akka のすべてが非同期であるため、メッセージが非同期であることを保証できます。オペレーターを使用してメッセージを送信する場合!、メッセージはファイア アンド フォーゲット方式で送信されます。

詳しくはこちらをご覧ください。

Answer 2

PinnedDispatcherを使用してみる

設定例＆コードはこちら

制限付きメールボックスが使用されるまでブロックしない

Answer 3

実際、RoundRobinRouter (ルートの数は予想されるスレッドの数と等しい) とフラグ thread-pool-executor.allow-core-timeout=off を使用した PinnedDispatcher の私の場合の組み合わせについては、すべての応答に感謝します。