2 writes to DegreeOfParallelism
System.Core (2)
System\Linq\Parallel\QueryOperators\QuerySettings.cs (1)
191
settings.
DegreeOfParallelism
= Scheduling.GetDefaultDegreeOfParallelism();
System\Linq\ParallelEnumerable.cs (1)
341
settings.
DegreeOfParallelism
= degreeOfParallelism;
21 references to DegreeOfParallelism
System.Core (21)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (1)
93
int partitionCount = settings.
DegreeOfParallelism
.Value;
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (2)
116
opSequential, m_settings.
DegreeOfParallelism
.Value, m_preferStriping);
122
PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource(this, m_settings.
DegreeOfParallelism
.Value, m_preferStriping);
System\Linq\Parallel\QueryOperators\PartitionerQueryOperator.cs (2)
136
Contract.Assert(m_settings.
DegreeOfParallelism
.HasValue);
137
int partitionCount = m_settings.
DegreeOfParallelism
.Value;
System\Linq\Parallel\QueryOperators\QueryOperator.cs (1)
187
Contract.Assert(querySettings.
DegreeOfParallelism
.HasValue);
System\Linq\Parallel\QueryOperators\QuerySettings.cs (10)
113
if (this.
DegreeOfParallelism
!= null && settings2.
DegreeOfParallelism
!= null)
134
int? dop = this.
DegreeOfParallelism
.HasValue ? this.
DegreeOfParallelism
: settings2.
DegreeOfParallelism
;
154
QuerySettings settings = new QuerySettings(TaskScheduler,
DegreeOfParallelism
, CancellationState.ExternalCancellationToken, ExecutionMode, MergeOptions);
189
if (settings.
DegreeOfParallelism
== null)
210
Contract.Assert(settings.
DegreeOfParallelism
.HasValue);
211
Contract.Assert(settings.
DegreeOfParallelism
.Value >= 1 && settings.
DegreeOfParallelism
<= Scheduling.MAX_SUPPORTED_DOP);
System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (3)
65
Contract.Assert(settings.
DegreeOfParallelism
.HasValue);
70
return new ListQueryResults<TElement>(dataAsList, settings.
DegreeOfParallelism
.GetValueOrDefault(), preferStriping);
140
m_data, m_settings.
DegreeOfParallelism
.Value, false);
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (2)
122
opSequential, m_settings.
DegreeOfParallelism
.Value, m_preferStriping);
128
PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource(this, m_settings.
DegreeOfParallelism
.Value, m_preferStriping);