Esiste una classe di coda .NET che consente di eliminare più elementi contemporaneamente?

Question

Credo che uno scenario piuttosto comune sia quello di avere una coda di elementi che dovrebbero essere elaborati N alla volta.

Per esempio .. se abbiamo 23 items e dobbiamo elaborare 10 alla volta, sarebbe come:

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

posso risolvere questo problema in un variaty di modi. La mia domanda è: il framework .NET fornisce una classe progettata specificamente per affrontare questo scenario? La classe Queue sarebbe perfetta ma non consente di eliminare più elementi contemporaneamente.

Answer 1

È possibile creare un metodo di estensione sul 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(); 
     } 
    } 
} 

Usage:

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

Esempio:https://dotnetfiddle.net/OTcIZX

Answer 2

La libreria TPL Dataflow offre BatchBlock < T > che raggruppa la sequenza di input dei messaggi in blocchi della dimensione desiderata.

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();