1 write to _buffers
System.Linq.Parallel (1)
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (1)
81
_buffers
= buffers;
2 references to _buffers
System.Linq.Parallel (2)
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (2)
122
_buffers
[_partitionIndex].Enqueue(chunk[i]);
134
if (
_buffers
[_partitionIndex].Count >= OrderPreservingPipeliningMergeHelper<TOutput, TKey>.MAX_BUFFER_SIZE)