一度に複数の項目をデキューできる.NETキュークラスはありますか？

Question

かなり一般的なシナリオは、一度にN個処理されるべきアイテムのキューを持つことです。私はいくつかの方法variatyでこの問題を解決することができ

Process batch of 10 
Process batch of 10 
Process batch of 3 

：我々は23 itemsを持っており、一度に10を処理する必要がある場合のように例えば

は...、それは次のようになります。私の質問です：.NET Frameworkは、このシナリオに対処するために特別に設計されたクラスを提供していますか？ Queueクラスは完璧ですが、複数のアイテムを一度にデキューすることはできません。

Answer 1

あなたはQueue<T>に拡張メソッドを作成することができます。

public static class QueueExtensions 
{ 
    public static IEnumerable<T> DequeueChunk<T>(this Queue<T> queue, int chunkSize) 
    { 
     for (int i = 0; i < chunkSize && queue.Count > 0; i++) 
     { 
      yield return queue.Dequeue(); 
     } 
    } 
} 

使用法：

var q = new Queue<char>(); 
q.DequeueChunk(10) // first 10 items 
q.DequeueChunk(10) // next 10 items 

例：はhttps://dotnetfiddle.net/OTcIZX

Answer 2

TPLデータフローライブラリは、メッセージの入力シーケンスを希望のサイズのチャンクにグループ化することを提供します（BatchBlock < T >）。

var bb = new BatchBlock<int>(10); 
var ab = new ActionBlock<int[]>((Action<int[]>)chunk=>HandleChunk(chunk)); 

bb.LinkTo(ab, new DataflowLinkOptions(){PropogateCompletion = true}); 

for(int i = 0; i < 23; ++i) 
{ 
    bb.Post(i); 
} 

bb.Complete(); 
ab.Completion.Wait();