コレクションまたはデータ構造のいずれかがJavaでブロックされていない

Question

イベント処理では、関数は値をコレクションに入れ、別のものは同じコレクションから値を取り出します。アイテムは、ソース（ソケット）から受け取った順序でコレクション内に配置し、同じ方法で読み取る必要があります。そうしないと、結果が変更されます。

キューは、ほとんどの人が推薦するコレクションですが、同時にアイテムが追加されるとキューがブロックされるため、追加が完了するまで待たなければならず、効率が悪くなり、操作の待ち時間が長くなります。

たとえば、あるスレッドはキューから読み取り、別のスレッドは同じキューに書き込みます。いずれかの操作は、ロックを解除するまでキュー上で一度に実行されます。これを回避するデータ構造はありますか？

Answer 1

ConcurrentLinkedQueueは、例の1つです。 java.util.concurrentから他のクラスをご覧ください。

具体的なケースでは、さらに優れた第三者のライブラリがあります。 LMAX Disruptor

Answer 2

実際、LinkedBlockingQueueは、ブロックするputメソッドとtakeメソッドのために、使用するアイテムがあるまで待つのが最も簡単で、別のアイテムを挿入するスペースが、容量がアクティブになっています。容量の設定はオプションです。キューを無制限に拡張することはできません。

一方、ArrayBlockingQueueは、その中で最も効率的で美しいものです。内部でリングバッファを使用しているため、固定容量でなければなりません。これはLinkedBlockingQueueよりも高速ですが、ディスラプターで達成できる最大スループットからはかなり離れています。

どちらの場合でも、ブロッキングは純粋に両側でオプションです。すべての並行キューの非ブロッキングAPIもサポートされています。ブロッキングAPIとノンブロッキングAPIを混在させることができます。

多くの場合、キューはボトルネックではなく、実際には混乱を起こすことはしばしば賢明なことです。これは待ち行列ではなく、異なる役割を持つ参加スレッド間で共有されるリングバッファ、すなわち典型的には1人のプロデューサ、1人の作業者、および1人の消費者である。設定が少し面倒ですが、現代のハードウェアでは、高価な揮発性変数を必要としませんが、マシン依存の読み書きをよりシリアルにするために、1秒間に約100万トランザクションの処理速度が可能です（基本的に、 ）;