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

Task Con = new Task(Consumer);

// Запустить задачи.

Con.Start ;

Prod:Start;

// Ожидать завершения обеих задач, try {

Task.WaitAll(Con, Prod);

} catch(AggregateException exc) {

Console.WriteLine (exc);

} finally {

Con.Dispose ;

Prod.Dispose ; be.Dispose;

}

}

}

Еслизапустить эту программу на выполнение, то на экране появится смешанный результат, выводимый поставщиком и потребителем. Отчасти это объясняется тем, что коллекция Ьс ограничена 4 элементами, а это означает, что в нее может быть добавлено только четыре элемента, прежде чем ее придется сократить. В качестве эксперимента попробуйте сделать коллекцию Ьс неограниченной и понаблюдайте за полученными результатами. В некоторых средах выполнения это приведет к тому, что все элементы коллекции будут сформированы до того, как начнется какое-либо их потребление. Кроме того, попробуйте ограничить коллекцию одним элементом. В этом случае одновременно может быть сформирован лишь один элемент.

Для работы с коллекцией типаBlockingCollectionможет оказаться полезным и методCompleteAdding . Ниже приведена форма его объявления.

public void CompleteAdding

Вызов этого метода означает, что в коллекцию не будет больше добавлено ни одного элемента. Это приводит к тому, что свойствоIsAddingCompleteпринимает логическое значениеtrue.Если же коллекция пуста, то свойствоIsCompletedпринимает логическое значениеtrue,и в этом случае вызовы методаТаке не блокируются. Ниже приведены формы объявления свойствIsAddingCompleteиIsCompleted.

public bool IsCompleted { get; } public bool IsAddingComplete { get; }

Когда коллекция типаBlockingCollectionтолько начинает формироваться, эти свойства содержат логическое значениеfalse.А после вызова методаCompleteAdding они принимают логическое значениеtrue.

Ниже приведен вариант предыдущего примера программы, измененный с целью продемонстрировать применение методаCompleteAdding , свойстваIsCompletedи методаTryTake .

// Применение методов CompleteAdding, TryTake и свойства IsCompleted. 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);

}

be.CompleteAdding;

}

// Потреблять символы до тех пор, пока их будет производить поставщик.

static void Consumer    {

char ch;

while(!be.IsCompleted) { if(be.TryTake(out ch))

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

}

}