2 writes to TaskScheduler
System.Core (2)
System\Linq\Parallel\QueryOperators\QuerySettings.cs (1)
186
settings.
TaskScheduler
= TaskScheduler.Default;
System\Linq\ParallelEnumerable.cs (1)
309
settings.
TaskScheduler
= taskScheduler;
14 references to TaskScheduler
System.Core (14)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (2)
97
false, ParallelMergeOptions.FullyBuffered, settings.
TaskScheduler
, m_leftChild.OutputOrdered,
107
false, ParallelMergeOptions.FullyBuffered, settings.
TaskScheduler
, m_rightChild.OutputOrdered,
System\Linq\Parallel\QueryOperators\QueryOperator.cs (4)
163
querySettings.
TaskScheduler
,
186
Contract.Assert(querySettings.
TaskScheduler
!= null);
231
new PartitionedStreamMerger<TOutput>(false, ParallelMergeOptions.FullyBuffered, querySettings.
TaskScheduler
,
280
TaskScheduler taskScheduler = settings.
TaskScheduler
;
System\Linq\Parallel\QueryOperators\QuerySettings.cs (8)
108
if (this.
TaskScheduler
!= null && settings2.
TaskScheduler
!= null)
133
TaskScheduler tm = (this.
TaskScheduler
== null) ? settings2.
TaskScheduler
: this.
TaskScheduler
;
154
QuerySettings settings = new QuerySettings(
TaskScheduler
, DegreeOfParallelism, CancellationState.ExternalCancellationToken, ExecutionMode, MergeOptions);
184
if (settings.
TaskScheduler
== null)
209
Contract.Assert(settings.
TaskScheduler
!= null);