2 writes to DegreeOfParallelism
System.Linq.Parallel (2)
System\Linq\Parallel\QueryOperators\QuerySettings.cs (1)
177settings.DegreeOfParallelism ??= Scheduling.GetDefaultDegreeOfParallelism();
System\Linq\ParallelEnumerable.cs (1)
301settings.DegreeOfParallelism = degreeOfParallelism;
25 references to DegreeOfParallelism
System.Linq.Parallel (25)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (2)
88Debug.Assert(settings.DegreeOfParallelism != null); 89int partitionCount = settings.DegreeOfParallelism.Value;
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (4)
110Debug.Assert(_settings.DegreeOfParallelism != null); 114opSequential, _settings.DegreeOfParallelism.Value, _preferStriping); 119Debug.Assert(_settings.DegreeOfParallelism != null); 121PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource(this, _settings.DegreeOfParallelism.Value, _preferStriping);
System\Linq\Parallel\QueryOperators\PartitionerQueryOperator.cs (2)
130Debug.Assert(_settings.DegreeOfParallelism.HasValue); 131int partitionCount = _settings.DegreeOfParallelism.Value;
System\Linq\Parallel\QueryOperators\QueryOperator.cs (1)
179Debug.Assert(querySettings.DegreeOfParallelism.HasValue);
System\Linq\Parallel\QueryOperators\QuerySettings.cs (9)
106if (this.DegreeOfParallelism != null && settings2.DegreeOfParallelism != null) 127int? dop = this.DegreeOfParallelism.HasValue ? this.DegreeOfParallelism : settings2.DegreeOfParallelism; 147QuerySettings settings = new QuerySettings(TaskScheduler, DegreeOfParallelism, CancellationState.ExternalCancellationToken, ExecutionMode, MergeOptions); 186Debug.Assert(settings.DegreeOfParallelism.HasValue); 187Debug.Assert(settings.DegreeOfParallelism.Value >= 1 && settings.DegreeOfParallelism <= Scheduling.MAX_SUPPORTED_DOP);
System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (4)
59Debug.Assert(settings.DegreeOfParallelism.HasValue); 63return new ListQueryResults<TElement>(dataAsList, settings.DegreeOfParallelism.GetValueOrDefault(), preferStriping); 131Debug.Assert(_settings.DegreeOfParallelism != null); 134_data, _settings.DegreeOfParallelism.Value, false);
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (3)
112Debug.Assert(_settings.ExecutionMode != null && _settings.DegreeOfParallelism != null); 118opSequential, _settings.DegreeOfParallelism.Value, _preferStriping); 124PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource(this, _settings.DegreeOfParallelism.Value, _preferStriping);