1 write to _syncChannels
System.Linq.Parallel (1)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
81_syncChannels =
11 references to _syncChannels
System.Linq.Parallel (11)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (11)
83_channelEnumerator = new SynchronousChannelMergeEnumerator<TInputOutput>(_taskGroupState, _syncChannels); 87Debug.Assert(_syncChannels == null || _syncChannels.Length == partitions.PartitionCount); 106else if (_syncChannels != null) 108SpoolingTask.SpoolStopAndGo<TInputOutput, TIgnoreKey>(_taskGroupState, _partitions, _syncChannels, _taskScheduler); 142if (_syncChannels != null) 146for (int i = 0; i < _syncChannels.Length; i++) 148totalSize += _syncChannels[i].Count; 154for (int i = 0; i < _syncChannels.Length; i++) 156_syncChannels[i].CopyTo(array, current); 157current += _syncChannels[i].Count;