从 BlockingCollection 中删除项目

Question

如何从 BlockingCollection 中删除项目？以下哪项是正确的？

myBlockingCollection.Remove(Item);

或者

myBlockingCollection.Take(Item);

Answer 1

您无法指定要从 BlockingCollection 中删除的特定项目。

Take() 方法从底层集合中删除一个项目并返回删除的项目。

TryTake(out T item) 方法从基础集合中删除一个项目，并将删除的项目分配给 out 参数。如果可以删除某个项目，则该方法返回 true；否则返回 true。否则为假。

删除的项目取决于 BlockingCollection 使用的底层集合 - 例如，ConcurrentStack 将具有 LIFO 行为，而 ConcurrentQueue; 将具有 FIFO 行为。

Answer 2

这段代码怎么样？ - 它正在工作，但改变了集合的顺序。 （而且我没有在多线程状态下检查它）。

public static bool Remove<T>(this BlockingCollection<T> self, T itemToRemove)
    {
        lock (self)
        {
            T comparedItem;
            var itemsList = new List<T>();
            do
            {
                var result = self.TryTake(out comparedItem);
                if (!result)
                    return false;
                if (!comparedItem.Equals(itemToRemove))
                {
                    itemsList.Add(comparedItem);
                }
            } while (!(comparedItem.Equals(itemToRemove)));
            Parallel.ForEach(itemsList, t => self.Add(t));
        }
        return true;
    }

Answer 3

我认为只有 TryTake() 是一个选项？我在 MSDN 上找不到有关 Remove() 方法的文档。

Answer 4

我认为 TryTake(out item) 会起作用。 BlockingCollection 类中不存在Remove，并且Take 不将item 作为参数。