1 write to _mergeHelper
System.Linq.Parallel (1)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
254_mergeHelper = mergeHelper;
15 references to _mergeHelper
System.Linq.Parallel (15)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (15)
286for (int producer = 0; producer < _mergeHelper._partitions.PartitionCount; producer++) 354if (_mergeHelper._taskGroupState.CancellationState.MergedCancellationToken.IsCancellationRequested) 361object[] locks = _mergeHelper._bufferLocks; 392Queue<Pair<TKey, TOutput>> buffer = _mergeHelper._buffers[producer]; 393object bufferLock = _mergeHelper._bufferLocks[producer]; 400if (_mergeHelper._producerDone[producer]) 409_mergeHelper._consumerWaiting[producer] = true; 415Debug.Assert(_mergeHelper._producerDone[producer]); 425if (_mergeHelper._producerWaiting[producer]) 429_mergeHelper._producerWaiting[producer] = false; 441_privateBuffer[producer] = _mergeHelper._buffers[producer]; 444_mergeHelper._buffers[producer] = new Queue<Pair<TKey, TOutput>>(INITIAL_BUFFER_SIZE); 482int partitionCount = _mergeHelper._buffers.Length; 485object bufferLock = _mergeHelper._bufferLocks[producer]; 488if (_mergeHelper._producerWaiting[producer])