1 instantiation of OrderPreservingPipeliningMergeHelper
System.Linq.Parallel (1)
System\Linq\Parallel\Merging\MergeExecutor.cs (1)
69
mergeExecutor._mergeHelper = new
OrderPreservingPipeliningMergeHelper
<TInputOutput, TKey>(
4 references to OrderPreservingPipeliningMergeHelper
System.Linq.Parallel (4)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (2)
213
private readonly
OrderPreservingPipeliningMergeHelper
<TOutput, TKey> _mergeHelper;
249
internal OrderedPipeliningMergeEnumerator(
OrderPreservingPipeliningMergeHelper
<TOutput, TKey> mergeHelper, IComparer<Producer<TKey>> producerComparer)
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (2)
134
if (_buffers[_partitionIndex].Count >=
OrderPreservingPipeliningMergeHelper
<TOutput, TKey>.MAX_BUFFER_SIZE)
164
buffers[i] = new Queue<Pair<TKey, TOutput>>(
OrderPreservingPipeliningMergeHelper
<TOutput, TKey>.INITIAL_BUFFER_SIZE);