c# - 队列中有新项目时如何出队

Question

我有一个使用带有字符串的队列的应用程序(对应于应用程序需要执行的不同任务)。在随机的时刻，队列可能会充满字符串(有时一分钟几次，但也可能需要几个小时。

直到现在，我总是有一个计时器每隔几秒检查一次队列中是否有项目并将其删除。

我认为一定有比这种方式更好的解决方案。当一个项目被添加到队列时，有什么方法可以得到一个事件吗？

Answer 1

是的。看看TPL Dataflow ，特别是 BufferBlock<T> ，它或多或少与 BlockingCollection 相同没有通过利用 async/await 阻塞你的线程的讨厌的副作用.

所以你可以:

void Main()
{
    var b = new BufferBlock<string>();
    AddToBlockAsync(b);
    ReadFromBlockAsync(b);
}

public async Task AddToBlockAsync(BufferBlock<string> b)
{
    while (true)
    {
        b.Post("hello");
        await Task.Delay(1000);
    }
}

public async Task ReadFromBlockAsync(BufferBlock<string> b)
{
    await Task.Delay(10000); //let some messages buffer up...
    while(true)
    {
        var msg = await b.ReceiveAsync();
        Console.WriteLine(msg);
    }
}