BlockingCollection<T> 中的 IsCompleted 属性是否实际阻塞？

Question

我正在尝试为我从控制器异步读取的数据流实现生产者/消费者模式。我想使用BlockingCollection<T> 这样做，但想确保我得到想要的结果。我的消费者看起来像这样：

// make sure there is actually some data in the buffer
if (!this.buffer.IsCompleted)
{
    // attempt to read from the buffer
    data = this.buffer.Take();

    // construct the message object
    message = this.ConvertToMessageObject(data);
}

IsCompleted 属性实际上会阻塞吗？因此，如果另一个线程要访问缓冲区，我希望它在调用 Take 方法之前等待并确保缓冲区实际上没有“完成”。

在我的应用程序中，期望的效果是允许我避免在缓冲区实际上为空时构造新的消息对象。所以这就是为什么我在去Take之前检查IsCompleted。

另外...我知道Take 方法不再阻塞一次IsAddingCompleted = true。因此，我不希望消费者从无效的 Take 方法中获取数据，因为它别无选择（如果消费者不知道已完成状态）。我认为我很难解释我在这里担心的事情......

Answer 1

IsCompleted 属性实际上会阻塞吗？

不，它会立即返回。

因此，如果另一个线程要访问缓冲区，我希望它等待并确保在调用 Take 方法之前缓冲区实际上没有“完成”。

这样做。当然，如果调用IsCompleted 时缓冲区未完成，它将返回false。它可能在返回该值之后完成，并且在您调用IsCompleted 时队列中可能没有任何项目。

在我的应用程序中，期望的效果是允许我避免在缓冲区实际上为空时构造新的消息对象。

Take 如果集合被阻塞并且其中没有项目，则将抛出异常，因此您无需担心。它不会永远阻塞，也不会在没有任何实际数据的情况下构造新消息。完成后，您可以在循环外捕获异常以继续。

话虽如此，让BlockingCollection 为您处理迭代要比尝试构建您自己的消耗迭代器要容易得多（尽管自己动手并不难） .你可以写：

foreach(var data in buffer.GetConsumingEnumerable())
    //...

它将消耗序列中的项目，直到缓冲区完成，然后在缓冲区中没有并且永远不会有任何项目时退出循环。