9 references to Task
System.Linq.Parallel (1)
System\Linq\Parallel\Scheduling\QueryTask.cs (1)
64
Task task = new
Task
(s_runTaskSynchronouslyDelegate, this, TaskCreationOptions.AttachedToParent);
System.Threading.Tasks.Dataflow (8)
Blocks\BatchBlock.cs (1)
641
_nonGreedyState!.TaskForInputProcessing = new
Task
(static thisBatchTarget => ((BatchBlockTargetCore)thisBatchTarget!).ProcessMessagesLoopCore(), this,
Blocks\BroadcastBlock.cs (2)
260
new
Task
(static state => ((BroadcastBlock<T>)state!).ConsumeMessagesLoopCore(), this,
837
_taskForOutputProcessing = new
Task
(static thisSourceCore => ((BroadcastingSourceCore<TOutput>)thisSourceCore!).OfferMessagesLoopCore(), this,
Blocks\BufferBlock.cs (1)
261
new
Task
(static state => ((BufferBlock<T>)state!).ConsumeMessagesLoopCore(), this,
Blocks\JoinBlock.cs (1)
1282
_taskForInputProcessing = new
Task
(static thisSharedResources => ((JoinBlockTargetSharedResources)thisSharedResources!).ProcessMessagesLoopCore(), this,
Blocks\WriteOnceBlock.cs (1)
123
var taskForOutputProcessing = new
Task
(static state => ((WriteOnceBlock<T>)state!).OfferToTargetsAndCompleteBlock(), this,
Internal\SourceCore.cs (1)
759
_taskForOutputProcessing = new
Task
(static thisSourceCore => ((SourceCore<TOutput>)thisSourceCore!).OfferMessagesLoopCore(), this,
Internal\TargetCore.cs (1)
372
var taskForInputProcessing = new
Task
(static thisTargetCore => ((TargetCore<TInput>)thisTargetCore!).ProcessMessagesLoopCore(), this,