Collections.synchronizedlist（）は、反復処理中に要素を削除します。

Question

私はCollections.Synchronizedlist()を使用して、arraylistをスレッドセーフにしています。私がお聞きしたいのは端からリストを反復処理しながら、すなわち削除し、次のコードをスレッドセーフである： -

pendingExecutionList = Collections.synchronizedList(new ArrayList<>(initialCapacity)); 

私はメインスレッドでリストを作成しています。異なるスレッドからこのリストに追加します。しかし、反復及び除去以下に示すように、単一のスケジュールスレッドから行われている： -

for (int i = pendingExecutionList.size() - 1; i >= 0; i--) 
{ 
    if (someCondition(pendingExecutionList.get(i))) 
    { 
     process(pendingExecutionList.remove(i)); 
    } 
} 

複数のスレッドがこのリストに追加されている間、上記のコードは、単一のスレッドによって実行されます。

synchronized(list)以上の反復子は、フェイルセーフではないので、使用しないでください。

Answer 1

ワークフローのパイプラインを正しく理解している場合は、synchronizedList()の代わりにBlockingQueueのいくつかの変形を試すことをおすすめします。

ArrayBlockingQueue実行の公平なスケジューリングを可能にし、複数のプロデューサのキャッシュをかなり高温に保つ必要があります（プロデューサがキャッシュプリフェッチャーを追い抜かない場合は、誤った共有が発生します）。

実験の気分があれば、Nitsan WakartのMpscArrayQueueまたはDisruptorのように、JDKの外部で利用可能なMPSC（複数のプロデューサ、単一消費者）キューを見ることができます。

Answer 2

ロックを保持する代わりに、要素ごとにロックを実際に取得しています。これは、小切手をしている間だけロックを保持するよりも遅くなるリスクがあります。

PriorityQueueを適切な順序で使用することをお勧めします。これにより、次に処理する予定のものが開始時に表示され、待機中のタスクの数に関係なく、削除のコストは比較的安くなるように、キューが順序付けされます。