Parallel.ForEach循環與BlockingCollection.GetConsumableEnumerable

Question

爲什麼在使用GetConsumableEnumerable時，parallel.ForEach循環會退出OperationCancelledException？

//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

使用Parallel.ForEach與BlockingCollection是有點問題，因爲我最近發現。它可以工作，但它需要一點額外的努力。

Stephen Toub有一個excellent blog post on it，如果你下載了"Parallel Extension Extras"項目（also available on NuGet），你會發現一些代碼準備好幫助你。