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