1 write to _taskGroupState
System.Linq.Parallel (1)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
126
_taskGroupState
= new QueryTaskGroupState(cancellationState, queryId);
3 references to _taskGroupState
System.Linq.Parallel (3)
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (3)
155
_taskGroupState
, _partitions, _consumerWaiting, _producerWaiting, _producerDone,
250
: base(mergeHelper.
_taskGroupState
)
354
if (_mergeHelper.
_taskGroupState
.CancellationState.MergedCancellationToken.IsCancellationRequested)