1 type derived from QueryTask
System.Linq.Parallel (1)
System\Linq\Parallel\Scheduling\SpoolingTaskBase.cs (1)
22internal abstract class SpoolingTaskBase : QueryTask
10 references to QueryTask
System.Linq.Parallel (10)
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (1)
176QueryTask asyncTask = new OrderPreservingPipeliningSpoolingTask<TOutput, TKey>(
System\Linq\Parallel\Scheduling\OrderPreservingSpoolingTask.cs (2)
96QueryTask asyncTask = new OrderPreservingSpoolingTask<TInputOutput, TKey>( 103QueryTask syncTask = new OrderPreservingSpoolingTask<TInputOutput, TKey>(
System\Linq\Parallel\Scheduling\QueryTask.cs (2)
47((QueryTask)o).BaseWork(null); 76((QueryTask)o).BaseWork(null);
System\Linq\Parallel\Scheduling\SpoolingTask.cs (5)
52QueryTask asyncTask = new StopAndGoSpoolingTask<TInputOutput, TIgnoreKey>(i, groupState, partitions[i], channels[i]); 59QueryTask syncTask = new StopAndGoSpoolingTask<TInputOutput, TIgnoreKey>( 107QueryTask asyncTask = new PipelineSpoolingTask<TInputOutput, TIgnoreKey>(i, groupState, partitions[i], channels[i]); 150QueryTask asyncTask = new ForAllSpoolingTask<TInputOutput, TIgnoreKey>(i, groupState, partitions[i]); 157QueryTask syncTask = new ForAllSpoolingTask<TInputOutput, TIgnoreKey>(maxToRunInParallel, groupState, partitions[maxToRunInParallel]);