1 write to _partitionIndex
System.Linq.Parallel (1)
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (1)
80_partitionIndex = partitionIndex;
8 references to _partitionIndex
System.Linq.Parallel (8)
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (8)
122_buffers[_partitionIndex].Enqueue(chunk[i]); 125if (_consumerWaiting[_partitionIndex]) 128_consumerWaiting[_partitionIndex] = false; 134if (_buffers[_partitionIndex].Count >= OrderPreservingPipeliningMergeHelper<TOutput, TKey>.MAX_BUFFER_SIZE) 136_producerWaiting[_partitionIndex] = true; 201_producerDone[_partitionIndex] = true; 202if (_consumerWaiting[_partitionIndex]) 205_consumerWaiting[_partitionIndex] = false;