c#-4.0 - parallelism - vb net parallel programming examples

Parallel.ForEach loop con BlockingCollection.GetConsumableEnumerable

Question

¿Por qué parallel.ForEach loop sale con OperationCancelledException, mientras usa GetConsumableEnumerable?

//outside the function
static BlockingCollection<double> _collection = new BlockingCollection<double>();
var t = Task.Factory.StartNew(Producer);
Parallel.ForEach(_collection.GetConsumingEnumerable(),item => Console.WriteLine("Processed {0}", item));
Console.WriteLine("FINISHED processing");
public static void Producer()
{
var data = Enumerable.Range(1, 1000);
foreach (var i in data)
{
_collection.Add(i);
Console.WriteLine("Added {0}",i);
}
Console.WriteLine("Finished adding");
_collection.CompleteAdding();
}

Answer 1

Usar Parallel.ForEach con BlockingCollection es algo problemático, como descubrí recientemente. Se puede hacer que funcione, pero necesita un pequeño esfuerzo adicional.

Stephen Toub tiene una excelente publicación en el blog y si descargas el proyecto "Extras de la extensión paralela" ( también disponible en NuGet ) encontrarás un código listo para ayudarte.