Revision cd7c162f trunk/Pithos.Core/JobQueue.cs

b/trunk/Pithos.Core/JobQueue.cs
32 32 

  		





  33
  33
  
    
        private void ProcessUpdates()


  		





  34
  34
  
    
        {


  		





  
  35
  
    
            Parallel.ForEach(_statusUpdateQueue.GetConsumingEnumerable(),


  		





  
  36
  
    
                new ParallelOptions{MaxDegreeOfParallelism=1,CancellationToken=_cancellationToken},  


  		





  
  37
  
    
                action => action());


  		





  35
  38
  
    
            foreach (var action in _statusUpdateQueue.GetConsumingEnumerable())


  		





  36
  39
  
    
            {


  		





  37
  40
  
    
                action();


  		












Also available in:
  Unified diff