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

Usando 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 un excellent blog post on it, y si descarga el proyecto "Parallel Extension Extras" (also available on NuGet), encontrará algún código listo para ayudarlo.