複数のプロデューサーがあり、それぞれが独自のブロッキング キューにデータをプッシュします。各プロデューサーからのデータは個別に処理されます (したがって、個別のキューがあります)。
私の単一のコンシューマーは現在、これらのキューのそれぞれをポーリングし、それぞれにタイムアウトを設定しています。
プログラムは問題なく動作しますが、最適化しようとしています。「ポーリング」が好きではありません。これはこれにアプローチする最も効率的な方法ですか?,
プロデューサーごとにコンシューマーを使用して同じアプリを作成しましたが、プロファイルはわずかに悪化しました。
ありがとう 。