1 write to _producerHeap
System.Linq.Parallel (1)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
255_producerHeap = new FixedMaxHeap<Producer<TKey>>(partitionCount, producerComparer);
8 references to _producerHeap
System.Linq.Parallel (8)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (8)
267int producerToYield = _producerHeap.MaxValue.ProducerIndex; 294_producerHeap.Insert(new Producer<TKey>(element.First, producer)); 310if (_producerHeap.Count == 0) 321int lastProducer = _producerHeap.MaxValue.ProducerIndex; 329_producerHeap.ReplaceMax(new Producer<TKey>(element.First, lastProducer)); 340_producerHeap.RemoveMax(); 344return _producerHeap.Count > 0; 380_producerHeap.Clear();