（ scalaでコードスレッドを安全にする方法のフォローアップのようなものですか？ ）
私は本質的に1つのスレッドからのみ呼び出すことができるscalaクラスを持っています（それを呼びましょうclass ThreadUnsafeProducer）。ただし、正確に1つのオブジェクトにアクセスするスレッドを増やすことは安全です。ただし、これThreadUnsafeProducerは非常にメモリを大量に消費するため、各スレッドに1つを持たせたくありませんThreadUnsafeProducer。
与えられた数NのThreadUnsafeProducerオブジェクト（理想的にはCPUごとに1つ）が必要です。
Consumer同じオブジェクトを共有するスレッドがたくさんありますSharedObject。
どういうわけか、アクターモデルを使用して、 SharedObjectまたはThreadUnsafeProducer（どちらかはわかりませんが）指定された数の同時ThreadUnsafeProducer実行にメッセージを送信したいと思います。そして、私はすべてのAkka/Actorsクラスでかなり迷っています。