Удаление элемента из коллекции BlockingCollection

Question

Как можно удалить элемент из коллекции BlockingCollection?Что из следующего является правильным?

myBlockingCollection.Remove(Item);

или

myBlockingCollection.Take(Item);

Answer 1

Вы не можете указать конкретный элемент, который будет удален из BlockingCollection<T>.

Метод Take() удаляет элемент из базовой коллекции и возвращает удаленный элемент.

Метод TryTake(out T item) удаляет элемент из базовой коллекции и назначает удаленный элемент параметру out. Метод возвращает true, если элемент может быть удален; иначе ложно.

Элемент, который удаляется, зависит от базовой коллекции, используемой BlockingCollection<T> - например, ConcurrentStack<T> будет иметь поведение LIFO, а ConcurrentQueue<T> будет работать FIFO.

Answer 2

Я думаю, что только TryTake () вариант?Я не могу найти документацию по методу Remove () на MSDN .

Answer 3

А как насчет этого кода? - Это работает, но измените порядок сбора. (И я не проверял это в состоянии нескольких потоков).

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 4

Я думаю TryTake(out item) будет работать.Remove не существует в классе BlockingCollection, а Take не принимает элемент в качестве параметра.