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)
1920
TaskScheduler scheduler = dataflowBlockOptions.
TaskScheduler
;
2007
TaskScheduler scheduler = dataflowBlockOptions.
TaskScheduler
;
Base\DataflowBlockOptions.cs (3)
95
TaskScheduler = this.
TaskScheduler
,
266
TaskScheduler = this.
TaskScheduler
,
398
TaskScheduler = this.
TaskScheduler
,
Blocks\BatchBlock.cs (1)
653
Exception? exception = Common.StartTaskSafe(_nonGreedyState.TaskForInputProcessing, _dataflowBlockOptions.
TaskScheduler
);
Blocks\BroadcastBlock.cs (2)
272
Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.
TaskScheduler
);
848
Exception? exception = Common.StartTaskSafe(_taskForOutputProcessing, _dataflowBlockOptions.
TaskScheduler
);
Blocks\BufferBlock.cs (1)
273
Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.
TaskScheduler
);
Blocks\JoinBlock.cs (1)
1294
Exception? exception = Common.StartTaskSafe(_taskForInputProcessing, _dataflowBlockOptions.
TaskScheduler
);
Blocks\TransformManyBlock.cs (1)
247
_source.DataflowBlockOptions.
TaskScheduler
);
Blocks\WriteOnceBlock.cs (1)
134
Exception? exception = Common.StartTaskSafe(taskForOutputProcessing, _dataflowBlockOptions.
TaskScheduler
);
Internal\SourceCore.cs (1)
770
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
);