Parallel.ForEach loop con BlockingCollection.GetConsumableEnumerable

Question

Perché parallel.ForEach termina con OperationCancelledException, mentre si utilizza 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

Utilizzando Parallel.ForEach con BlockingCollection è un po 'problematico, come ho scoperto di recente. Può essere fatto funzionare, ma richiede un piccolo sforzo in più.

Stephen Toub ha uno excellent blog post on it e se si scarica il progetto "Parallel Extension Extras" (also available on NuGet), è disponibile un codice pronto per essere d'aiuto.