Как видите, в нескольких классах параллельных коллекций реализуется интерфейсIProducerConsumerCollection.Этот интерфейс также определен в пространстве именSystem. Collections . Concurrent.Он служит в качестве расширения интерфейсовIEnumerable, IEnumerableиICollection.Кроме того, в нем определены методыTryAdd () иTryTake , поддерживающие шаблон "поставщик-потребитель". (Классический шаблон "поставщик-потребитель" отличается решением двух задач. Первая задача производит элементы коллекции, а другая потребляет их.) МетодTryAdd пытается добавить элемент в коллекцию, а методTryTake — удалить элемент из коллекции. Ниже приведены формы объявления обоих методов.
bool TryAdd(Тitem)bool TryTake(out Titem)
МетодTryAdd возвращает логическое значениеtrue,если в коллекцию добавлен элементitem.А методTryTake возвращает логическое значениеtrue,если элементitemудален из коллекции. Если методTryAdd выполнен успешно, то элементiternбудет содержать объект. (Кроме того, в интерфейсеIProducerConsumerCollectionуказывается перегружаемый вариант методаCopyTo, определяемого в интерфейсеICollection,а также метода ТоАггау , копирующего коллекцию в массив.)
Параллельные коллекции зачастую применяются в комбинации с библиотекой распараллеливания задач (TPL) или языком PLINQ. В силу особого характера этих коллекций все их классы не будут рассматриваться далее подробно. Вместо этого на конкретных примерах будет дан краткий обзор классаBlockingCollection.Усвоив основы построения классаBlockingCollection,вы сможете без особого труда разобраться и в остальных классах параллельных коллекций.
В классеBlockingCollection,по существу, реализуется блокирующая очередь. Это означает, что в такой очереди автоматически устанавливается ожидание любых попыток вставить элемент в коллекцию, когда она заполнена, а также попыток удалить элемент из коллекции, когда она пуста. Это идеальное решение для тех ситуаций, которые связаны с применением шаблона "поставщик-потребитель". В классеBlockingCollectionреализуются интерфейсыICollection, IEnumerable, IEnumerable,а такжеIDisposable.
В классеBlockingCollectionопределяются следующие конструкторы.
public BlockingCollection
public BlockingCollection(intboundedCapacity)
public BlockingCollection(IProducerConsumerCollectioncollection)public BlockingCollection(IProducerConsumerCollectioncollection,
intboundedCapacity)