3 instantiations of QueryTaskGroupState
System.Linq.Parallel (3)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
50_taskGroupState = new QueryTaskGroupState(cancellationState, queryId);
System\Linq\Parallel\Merging\OrderPreservingMergeHelper.cs (1)
45_taskGroupState = new QueryTaskGroupState(cancellationState, queryId);
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
126_taskGroupState = new QueryTaskGroupState(cancellationState, queryId);
24 references to QueryTaskGroupState
System.Linq.Parallel (24)
System\Linq\Parallel\Merging\AsynchronousChannelMergeEnumerator.cs (1)
45QueryTaskGroupState taskGroupState, AsynchronousChannel<T>[] channels, IntValueEvent? consumerEvent)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
28private readonly QueryTaskGroupState _taskGroupState; // State shared among tasks.
System\Linq\Parallel\Merging\MergeEnumerator.cs (2)
22protected QueryTaskGroupState _taskGroupState; 28protected MergeEnumerator(QueryTaskGroupState taskGroupState)
System\Linq\Parallel\Merging\OrderPreservingMergeHelper.cs (1)
25private readonly QueryTaskGroupState _taskGroupState; // State shared among tasks.
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
44private readonly QueryTaskGroupState _taskGroupState; // State shared among tasks.
System\Linq\Parallel\Merging\SynchronousChannelMergeEnumerator.cs (1)
34QueryTaskGroupState taskGroupState, SynchronousChannel<T>[] channels) : base(taskGroupState)
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (3)
26private readonly QueryTaskGroupState _taskGroupState; // State shared among tasks. 57QueryTaskGroupState taskGroupState, 148QueryTaskGroupState groupState, PartitionedStream<TOutput, TKey> partitions,
System\Linq\Parallel\Scheduling\OrderPreservingSpoolingTask.cs (2)
44int taskIndex, QueryTaskGroupState groupState, 71QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TKey> partitions,
System\Linq\Parallel\Scheduling\QueryTask.cs (2)
27protected QueryTaskGroupState _groupState; // State shared among the tasks. 33protected QueryTask(int taskIndex, QueryTaskGroupState groupState)
System\Linq\Parallel\Scheduling\SpoolingTask.cs (6)
33QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TIgnoreKey> partitions, 89QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TIgnoreKey> partitions, 134QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TIgnoreKey> partitions, TaskScheduler taskScheduler) 203int taskIndex, QueryTaskGroupState groupState, 292int taskIndex, QueryTaskGroupState groupState, 376int taskIndex, QueryTaskGroupState groupState,
System\Linq\Parallel\Scheduling\SpoolingTaskBase.cs (1)
31protected SpoolingTaskBase(int taskIndex, QueryTaskGroupState groupState) :
System\Linq\Parallel\Utils\Sorting.cs (3)
42private readonly QueryTaskGroupState _groupState; // To communicate status, e.g. cancellation. 58QueryTaskGroupState groupState, int[][] sharedIndices, 102PartitionedStream<TInputOutput, TKey> partitions, QueryTaskGroupState groupState)