1 write to _buffers
System.Linq.Parallel (1)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
132
_buffers
= new Queue<Pair<TKey, TOutput>>[partitionCount];
5 references to _buffers
System.Linq.Parallel (5)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (5)
156
_buffers
, _bufferLocks, _taskScheduler, _autoBuffered);
392
Queue<Pair<TKey, TOutput>> buffer = _mergeHelper.
_buffers
[producer];
441
_privateBuffer[producer] = _mergeHelper.
_buffers
[producer];
444
_mergeHelper.
_buffers
[producer] = new Queue<Pair<TKey, TOutput>>(INITIAL_BUFFER_SIZE);
482
int partitionCount = _mergeHelper.
_buffers
.Length;