Có lớp xếp hàng .NET cho phép xóa nhiều mục cùng lúc không?

Question

Tôi tin rằng một trường hợp khá phổ biến là có một hàng đợi các mục cần được xử lý N tại một thời điểm.

Ví dụ .. nếu chúng ta có 23 items và cần xử lý 10 cùng một lúc, nó sẽ như thế nào:

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

tôi có thể giải quyết vấn đề này trong một variaty cách khác nhau. Câu hỏi của tôi là: Khuôn khổ .NET có cung cấp bất kỳ lớp nào được thiết kế đặc biệt để giải quyết kịch bản này không? Lớp Queue sẽ hoàn hảo nhưng không cho phép khử nhiều mục cùng một lúc.

Answer 1

Bạn có thể tạo ra một phương pháp mở rộng trên 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(); 
     } 
    } 
} 

Cách sử dụng:

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

Ví dụ:https://dotnetfiddle.net/OTcIZX

Answer 2

Thư viện lưu trữ TPL Dataflow cung cấp BatchBlock < T > nhóm các chuỗi thư đầu vào thành các đoạn có kích thước mong muốn.

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