2 instantiations of Producer
System.Core (2)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (2)
293m_producerHeap.Insert(new Producer<TKey>(element.First, producer)); 328m_producerHeap.ReplaceMax(new Producer<TKey>(element.First, lastProducer));
11 references to Producer
System.Core (11)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (11)
87private IComparer<Producer<TKey>> m_producerComparer; 140m_producerComparer = (IComparer<Producer<TKey>>)(object)new ProducerComparerInt(); 188private class ProducerComparer : IComparer<Producer<TKey>> 197public int Compare(Producer<TKey> x, Producer<TKey> y) 220private readonly FixedMaxHeap<Producer<TKey>> m_producerHeap; 248internal OrderedPipeliningMergeEnumerator(OrderPreservingPipeliningMergeHelper<TOutput, TKey> mergeHelper, IComparer<Producer<TKey>> producerComparer) 254m_producerHeap = new FixedMaxHeap<Producer<TKey>>(partitionCount, producerComparer); 519internal class ProducerComparerInt : IComparer<Producer<int>> 521public int Compare(Producer<int> x, Producer<int> y)