允许我等待一个生产者的 ConcurrentQueue

Question

我有生产者/消费者的问题。目前我有一个简单的Queue 被lock 包围。

我正在尝试用更高效的方法来替换它。

我的第一选择是使用ConcurrentQueue，但我不知道如何让我的消费者等待下一条生成的消息（不执行 Thread.Sleep）。

另外，如果队列的大小达到特定数字，我希望能够清除整个队列。

您能否推荐一些符合我要求的现有类或实现？

Answer 1

这是一个示例，说明如何使用 BlockingCollection 类来做你想做的事：

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;
    }
}