1 write to m_producerHeap
System.Core (1)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
254m_producerHeap = new FixedMaxHeap<Producer<TKey>>(partitionCount, producerComparer);
8 references to m_producerHeap
System.Core (8)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (8)
266int producerToYield = m_producerHeap.MaxValue.ProducerIndex; 293m_producerHeap.Insert(new Producer<TKey>(element.First, producer)); 309if (m_producerHeap.Count == 0) 320int lastProducer = m_producerHeap.MaxValue.ProducerIndex; 328m_producerHeap.ReplaceMax(new Producer<TKey>(element.First, lastProducer)); 339m_producerHeap.RemoveMax(); 343return m_producerHeap.Count > 0; 377m_producerHeap.Clear();