C# 4.0 полное руководство - 2011

В двух первых конструкторах в оболочку классаBlockingCollectionзаключается коллекция, являющаяся экземпляром объекта типаConcurrentQueue.А в двух других конструкторах можно указать коллекцию, которая должна быть положена в основу коллекции типаBlockingCollection.Если указывается параметрboundedCapaci ty,то он должен содержать максимальное количество объектов, которые коллекция должна содержать перед тем, как она окажется заблокированной. Если же параметрboundedCapaci tyне указан, то коллекция оказывается неограниченной.

Помимо методовTryAdd () иTryTake , определяемых параллельно с теми, что указываются в интерфейсеIProducerConsumerCollection,в классеBlockingCollectionопределяется также ряд собственных методов. Ниже представлены методы, которые будут использоваться в приведенных далее примерах.

public void Add(Titem)public T Take

Когда методAdd вызывается для неограниченной коллекции, он добавляет элементitemв коллекцию и затем возвращает управление вызывающей части программы. А когда методAdd вызывается для ограниченной коллекции, он блокирует доступ к ней, если она заполнена. После того как из коллекции будет удален один элемент или больше, указанный элементitemбудет добавлен в коллекцию, и затем произойдет возврат из данного метода. МетодТаке удаляет элемент из коллекции и возвращает управление вызывающей части программы. (Имеются также варианты обоих методов, принимающие в качестве параметра признак задачи как экземпляр объекта типаCancellationToken.)

Применяя методыAdd иТаке,можно реализовать простой шаблон "поставщик-потребитель", как показано в приведенном ниже примере программы. В этой программе создается поставщик, формирующий символы от А до Z, а также потребитель, получающий эти символы. При этом создается коллекция типаBlockingCollection,ограниченная 4 элементами.

// Простой пример коллекции типа BlockingCollection. using System;

using System.Threading.Tasks;

using System.Threading;

using System.Collections.Concurrent;

class BlockingDemo {

static BlockingCollection be;

// Произвести и поставить символы от А до Z. static void Producer    {

for(char ch = 'A'; ch <= 'Z'; ch++) { be.Add(ch);

Console.WriteLine ("Производится символ " + ch) ;

}

}

// Потребить 26 символов, static void Consumer    {

for(int i=0; i < 26; i++)

Console .WriteLine ("Потребляется символ " + bc.TakeO);

}

static void Main {

// Использовать блокирующую коллекцию, ограниченную 4 элементами, be = new BlockingCollection(4);

// Создать задачи поставщика и потребителя.

Task Prod = new Task(Producer);