3 writes to TaskScheduler
System.Threading.Tasks.Dataflow (3)
Base\DataflowBlockOptions.cs (3)
95
TaskScheduler
= this.TaskScheduler,
266
TaskScheduler
= this.TaskScheduler,
398
TaskScheduler
= this.TaskScheduler,
15 references to TaskScheduler
System.Threading.Tasks.Dataflow (15)
Base\DataflowBlock.cs (2)
1839
TaskScheduler scheduler = dataflowBlockOptions.
TaskScheduler
;
1926
TaskScheduler scheduler = dataflowBlockOptions.
TaskScheduler
;
Base\DataflowBlockOptions.cs (3)
95
TaskScheduler = this.
TaskScheduler
,
266
TaskScheduler = this.
TaskScheduler
,
398
TaskScheduler = this.
TaskScheduler
,
Blocks\BatchBlock.cs (1)
650
Exception? exception = Common.StartTaskSafe(_nonGreedyState.TaskForInputProcessing, _dataflowBlockOptions.
TaskScheduler
);
Blocks\BroadcastBlock.cs (2)
266
Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.
TaskScheduler
);
842
Exception? exception = Common.StartTaskSafe(_taskForOutputProcessing, _dataflowBlockOptions.
TaskScheduler
);
Blocks\BufferBlock.cs (1)
267
Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.
TaskScheduler
);
Blocks\JoinBlock.cs (1)
1279
Exception? exception = Common.StartTaskSafe(_taskForInputProcessing, _dataflowBlockOptions.
TaskScheduler
);
Blocks\TransformManyBlock.cs (1)
247
_source.DataflowBlockOptions.
TaskScheduler
);
Blocks\WriteOnceBlock.cs (1)
131
Exception? exception = Common.StartTaskSafe(taskForOutputProcessing, _dataflowBlockOptions.
TaskScheduler
);
Internal\SourceCore.cs (1)
764
Exception? exception = Common.StartTaskSafe(_taskForOutputProcessing, _dataflowBlockOptions.
TaskScheduler
);
Internal\SpscTargetCore.cs (1)
185
newConsumer.Start(_dataflowBlockOptions.
TaskScheduler
);
Internal\TargetCore.cs (1)
384
Exception? exception = Common.StartTaskSafe(taskForInputProcessing, _dataflowBlockOptions.
TaskScheduler
);