3 instantiations of QueryTaskGroupState
System.Core (3)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
54m_taskGroupState = new QueryTaskGroupState(cancellationState, queryId);
System\Linq\Parallel\Merging\OrderPreservingMergeHelper.cs (1)
49m_taskGroupState = new QueryTaskGroupState(cancellationState, queryId);
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
126m_taskGroupState = new QueryTaskGroupState(cancellationState, queryId);
24 references to QueryTaskGroupState
System.Core (24)
System\Linq\Parallel\Merging\AsynchronousChannelMergeEnumerator.cs (1)
48QueryTaskGroupState taskGroupState, AsynchronousChannel<T>[] channels, IntValueEvent consumerEvent)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
32private QueryTaskGroupState m_taskGroupState; // State shared among tasks.
System\Linq\Parallel\Merging\MergeEnumerator.cs (2)
26protected QueryTaskGroupState m_taskGroupState; 32protected MergeEnumerator(QueryTaskGroupState taskGroupState)
System\Linq\Parallel\Merging\OrderPreservingMergeHelper.cs (1)
29private QueryTaskGroupState m_taskGroupState; // State shared among tasks.
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)
44private readonly QueryTaskGroupState m_taskGroupState; // State shared among tasks.
System\Linq\Parallel\Merging\SynchronousChannelMergeEnumerator.cs (1)
40QueryTaskGroupState taskGroupState, SynchronousChannel<T>[] channels) : base(taskGroupState)
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (3)
27private readonly QueryTaskGroupState m_taskGroupState; // State shared among tasks. 59QueryTaskGroupState taskGroupState, 152QueryTaskGroupState groupState, PartitionedStream<TOutput, TKey> partitions,
System\Linq\Parallel\Scheduling\OrderPreservingSpoolingTask.cs (2)
48int taskIndex, QueryTaskGroupState groupState, 75QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TKey> partitions,
System\Linq\Parallel\Scheduling\QueryTask.cs (2)
32protected QueryTaskGroupState m_groupState; // State shared among the tasks. 38protected QueryTask(int taskIndex, QueryTaskGroupState groupState)
System\Linq\Parallel\Scheduling\SpoolingTask.cs (6)
38QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TIgnoreKey> partitions, 91QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TIgnoreKey> partitions, 137QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TIgnoreKey> partitions, TaskScheduler taskScheduler) 206int taskIndex, QueryTaskGroupState groupState, 295int taskIndex, QueryTaskGroupState groupState, 382int taskIndex, QueryTaskGroupState groupState,
System\Linq\Parallel\Scheduling\SpoolingTaskBase.cs (1)
35protected SpoolingTaskBase(int taskIndex, QueryTaskGroupState groupState) :
System\Linq\Parallel\Utils\Sorting.cs (3)
47private QueryTaskGroupState m_groupState; // To communicate status, e.g. cancellation. 63QueryTaskGroupState groupState, int[][] sharedIndices, 106PartitionedStream<TInputOutput, TKey> partitions, QueryTaskGroupState groupState)