当集合为空时，BlockingCollection TryTake 返回 false 而不是 block

Question

当 BlockingCollection 为空时，我从 BlockingCollection 的 TryTake 方法返回 false，尽管预期的行为是阻塞直到集合填满。

请注意，集合不是上限（这应该会影响 TryAdd 而不是 TryTake），并且为添加操作设置的 Timeout 尚未过去。

这是我对 BlockingCollection 对象的包装：

    public T TryTake(int timeoutMiliseconds)
    {
        var result = default(T);

        if (!_collection.TryTake(out result, timeoutMiliseconds))
        {
            throw new InvalidOperationException("Unable to get item from collection.");
        }

        return result;
    }

有什么想法会导致这种情况吗？

我已经根据这篇文章实现了生产者-消费者模式： Multithread processing of the SqlDataReader - Producer/Consumer design pattern

Answer 1

我终于意识到，正如 SO post 所展示的那样，我从 TryTake 中得到了错误，因为集合已被清空，并且我也将其标记为已完成（通过在集合上调用 CompleteAdding() 方法）。

所以为了解决这个问题，我在完成标志上添加了一个条件。

有人可能会争辩说，TryTake 永远不会返回 false，而已完成标志为 false。我不确定这总是正确的，所以我更愿意在这种情况下抛出错误。

    public T TryTake(int timeoutMiliseconds)
    {
        var result = default(T);

        if (!_collection.TryTake(out result, timeoutMiliseconds) 
            && !_collection.IsAddingCompleted)
        {
            throw new InvalidOperationException("Unable to get item from collection.");
        }

        return result;
    }

请注意，将TryTake 调用放在第一位，将IsAddingCompleted 放在第二位非常重要。否则，第一个条件可能会通过，然后您会立即阻止 TryTake。