JavaのBlockingQueue.drainTo（Collection）メソッドに相当するC＃はありますか？

Question

私は、複数のスレッドがキューの要素に貢献するマルチスレッドのC＃アプリケーションを構築しています。単一のスレッドが同じキューの要素を消費しています。私は、単一のスレッドが着信要素の要素のいくつかの縮小/マージを行うようにしたいので、理想的には、キュー上のすべての新しい要素を見て、それらを減らしてから、

while (true) 
{ 
    Collection<Elem> elements = queue.TakeAll(); 
    Collection<Elem> reducedElements = Reduce(elements); 
    for (Elem e in reducedElements) 
    { 
    process(e); 
    } 
} 

しかし、明らかにTakeAll（）メソッドはありません。 Javaの経験から、私はBlockingQueue's drainTo methodに慣れています。興味のあるものを提供しています。

キューが空になるまで、TryTakeを使って何かを実装できます。しかし、それは、生産スレッドが潜在的に忙しいかもしれないというリスクを伴い、減らして処理するコレクションの有限の終了を引き起こす可能性があります。私は基本的にキューからすべてを取り出し、それを空のままにしながら作業できるコレクションを提供する方法を探しています。

Answer 1

名前空間System.Collections.ConcurrentのConcurrentQueueを見てください。

このキューは、スレッドセーフな操作のために作成されています。

拡張メソッドを簡単に追加できます。

public static class Extensions 
{ 
    public static List<T> DrainTo<T>(this System.Collections.Concurrent.ConcurrentQueue<T> poConcurrentQueue) 
    { 
     List<T> loList = new List<T>(); 
     T loElement; 
     while (poConcurrentQueue.TryDequeue(out loElement)) 
      loList.Add(loElement); 
     return loList; 
    } 
} 

と

次のように使用します。

System.Collections.Concurrent.ConcurrentQueue<string> loConcurrentQueue = new System.Collections.Concurrent.ConcurrentQueue<string>(); 

loConcurrentQueue.Enqueue("Element1"); 
loConcurrentQueue.Enqueue("Element2"); 

var loList = loConcurrentQueue.DrainTo();