ConcurrentQueue cho phép tôi đợi một nhà sản xuất

Question

Tôi gặp vấn đề với Nhà sản xuất/Người tiêu dùng. Hiện tại tôi đã đơn giản Queue được bao quanh bởi một lock.

Tôi đang cố gắng thay thế bằng thứ gì đó hiệu quả hơn.

Lựa chọn đầu tiên của tôi là sử dụng ConcurrentQueue, nhưng tôi không thấy làm thế nào để người tiêu dùng của tôi chờ tin nhắn được sản xuất tiếp theo (mà không cần làm Thread.Sleep).

Ngoài ra, tôi muốn có thể xóa toàn bộ hàng đợi nếu kích thước của nó đạt đến một số cụ thể.

Bạn có thể đề xuất một số lớp hoặc triển khai hiện có phù hợp với yêu cầu của tôi không?

Answer 1

Dưới đây là một ví dụ về cách bạn có thể sử dụng lớp BlockingCollection để làm những gì bạn muốn:

BlockingCollection<int> blocking_collection = new BlockingCollection<int>(); 

//Create producer on a thread-pool thread 
Task.Run(() => 
{ 
    int number = 0; 

    while (true) 
    { 
     blocking_collection.Add(number++); 

     Thread.Sleep(100); //simulating that the producer produces ~10 items every second 
    } 
}); 

int max_size = 10; //Maximum items to have 

int items_to_skip = 0; 

//Consumer 
foreach (var item in blocking_collection.GetConsumingEnumerable()) 
{ 
    if (items_to_skip > 0) 
    { 
     items_to_skip--; //quickly skip items (to meet the clearing requirement) 
     continue; 
    } 

    //process item 
    Console.WriteLine(item); 

    Thread.Sleep(200); //simulating that the consumer can only process ~5 items per second 

    var collection_size = blocking_collection.Count; 

    if (collection_size > max_size) //If we reach maximum size, we flag that we want to skip items 
    { 
     items_to_skip = collection_size; 
    } 
}