【C#】BlockingCollection 用法浅析

多线程操作集合时，ConcurrentQueue 是我常用的，一直用得也挺爽，突然发现了 BlockingCollection，原来还可以更简单。。。

BlockingCollection<T> 是一个自带阻塞功能的线程安全集合类，和 ConcurrentQueue<T> 有点像，不同的是，BlockingCollection<T> 自带阻塞功能。

• Add 方法用于向集合添加元素。
• Take 方法用于从集合中获取元素。当集合为空时，Take 方法将阻塞，直到获取到新元素。
• CompleteAdding 方法标记集合为完成状态，此后不能再向集合中添加元素，调用 Add 将抛出 System.InvalidOperationException 异常。
• 调用 CompleteAdding 方法将使阻塞状态的 Take 方法抛出 System.InvalidOperationException 异常。
• 实例化 BlockingCollection<T> 时，可以传入 boundedCapacity 参数，设置集合的上限，集合中元素到达上限后，Add 方法将阻塞。
• TryAdd 方法在集合满时，不会阻塞，而是直接返回 false，并且丢弃要插入的元素。
• TryTake 方法在集合为空时不会阻塞，而是会返回 false。
• 当有多个线程 Take 时，将形成一个 Take 队列，依次获取到元素。

这是 MSDN 上的 例子： https://docs.microsoft.com/zh-cn/dotnet/standard/collections/thread-safe/blockingcollection-overview

BlockingCollection<Data> dataItems = new BlockingCollection<Data>(100);

Task.Run(() =>
{
    while (!dataItems.IsCompleted)
    {
        Data data = null;
        try
        {
            data = dataItems.Take();
        }
        catch (InvalidOperationException) { }

        if (data != null)
        {
            Process(data);
        }
    }
    Console.WriteLine("\r\nNo more items to take.");
});