2 instantiations of FixedMaxHeap
System.Linq.Parallel (2)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
255
_producerHeap = new
FixedMaxHeap
<Producer<TKey>>(partitionCount, producerComparer);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)
108
FixedMaxHeap<TKey> sharedIndices = new
FixedMaxHeap
<TKey>(_count, inputStream.KeyComparer); // an array used to track the sequence of indices leading up to the Nth index
4 references to FixedMaxHeap
System.Linq.Parallel (4)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
221
private readonly
FixedMaxHeap
<Producer<TKey>> _producerHeap;
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (3)
108
FixedMaxHeap
<TKey> sharedIndices = new FixedMaxHeap<TKey>(_count, inputStream.KeyComparer); // an array used to track the sequence of indices leading up to the Nth index
159
private readonly
FixedMaxHeap
<TKey> _sharedIndices; // The indices shared among partitions.
172
FixedMaxHeap
<TKey> sharedIndices, CountdownEvent sharedBarrier, CancellationToken cancellationToken,