Как видите, в нескольких классах параллельных коллекций реализуется интерфейс
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(int
boundedCapacity)public BlockingCollection(IProducerConsumerCollection
collection)public BlockingCollection(IProducerConsumerCollectioncollection,int
boundedCapacity)