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); 392Queue<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); 482int partitionCount = _mergeHelper._buffers.Length;