从BlockingCollection中移除项目

问题描述

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

myBlockingCollection.Remove(Item);

要么

myBlockingCollection.Take(Item);

    

解决方法

您无法指定要从

BlockingCollection<T>

中删除的特定项目。

Take()

方法从基础集合中删除一个项目并返回删除的项目。

TryTake(out T item)

方法从基础集合中删除一个项目，并将删除的项目分配给

out

参数。如果可以删除某项，则该方法返回true；否则，该方法返回true。否则为假。 删除的项目取决于

BlockingCollection<T>

使用的基础集合-例如，

ConcurrentStack<T>

具有LIFO行为，

ConcurrentQueue<T>

具有FIFO行为。     ,我认为只有TryTake（）是一个选择？我在MSDN上的Remove（）方法上找不到文档。     ,这段代码呢？ -工作正常，但更改了收藏顺序。 （而且我没有在多线程状态下检查过它）。

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;
    }

    ,我认为10英镑可以用。在BlockingCollection类中不存在Remove，并且Take不将item作为参数。