1 write to _taskGroupState
System.Linq.Parallel (1)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
50
_taskGroupState
= new QueryTaskGroupState(cancellationState, queryId);
6 references to _taskGroupState
System.Linq.Parallel (6)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (6)
70
_channelEnumerator = new AsynchronousChannelMergeEnumerator<TInputOutput>(
_taskGroupState
, _asyncChannels, consumerEvent);
76
_channelEnumerator = ExceptionAggregator.WrapQueryEnumerator(partitions[0],
_taskGroupState
.CancellationState).GetEnumerator();
83
_channelEnumerator = new SynchronousChannelMergeEnumerator<TInputOutput>(
_taskGroupState
, _syncChannels);
104
SpoolingTask.SpoolPipeline<TInputOutput, TIgnoreKey>(
_taskGroupState
, _partitions, _asyncChannels, _taskScheduler);
108
SpoolingTask.SpoolStopAndGo<TInputOutput, TIgnoreKey>(
_taskGroupState
, _partitions, _syncChannels, _taskScheduler);
112
SpoolingTask.SpoolForAll<TInputOutput, TIgnoreKey>(
_taskGroupState
, _partitions, _taskScheduler);