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），你会发现一些代码准备好帮助你。