PartitionCount

System\Linq\Parallel\Merging\DefaultMergeHelper.cs (6)

65if (partitions.PartitionCount > 1) 69MergeExecutor<TInputOutput>.MakeAsynchronousChannels(partitions.PartitionCount, options, consumerEvent, cancellationState.MergedCancellationToken); 82MergeExecutor<TInputOutput>.MakeSynchronousChannels(partitions.PartitionCount); 86Debug.Assert(_asyncChannels == null || _asyncChannels.Length == partitions.PartitionCount); 87Debug.Assert(_syncChannels == null || _syncChannels.Length == partitions.PartitionCount); 118Debug.Assert(_partitions.PartitionCount == 1);

System\Linq\Parallel\Merging\MergeExecutor.cs (2)

54Debug.Assert(partitions.PartitionCount > 0); 65if (partitions.PartitionCount > 1)

System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (3)

131int partitionCount = _partitions.PartitionCount; 252int partitionCount = mergeHelper._partitions.PartitionCount; 286for (int producer = 0; producer < _mergeHelper._partitions.PartitionCount; producer++)

System\Linq\Parallel\Partitioning\OrderedHashRepartitionStream.cs (9)

System\Linq\Parallel\Partitioning\UnorderedHashRepartitionStream.cs (7)

25: base(inputStream.PartitionCount, Util.GetDefaultComparer<int>(), keyComparer, elementComparer) 28_partitions = new HashRepartitionEnumerator<TInputOutput, THashKey, TIgnoreKey>[inputStream.PartitionCount]; 32CountdownEvent barrier = new CountdownEvent(inputStream.PartitionCount); 34JaggedArray<ListChunk<Pair<TInputOutput, THashKey>>>.Allocate(inputStream.PartitionCount, inputStream.PartitionCount); 37for (int i = 0; i < inputStream.PartitionCount; i++) 40inputStream[i], inputStream.PartitionCount, i, keySelector, this,

System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (1)

185int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Binary\ConcatQueryOperator.cs (3)

84ExecuteAndCollectResults(leftStream, leftStream.PartitionCount, LeftChild.OutputOrdered, preferStriping, settings); 103ExecuteAndCollectResults(rightStream, leftStreamInc.PartitionCount, LeftChild.OutputOrdered, preferStriping, settings); 118int partitionCount = leftStreamInc.PartitionCount;

System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (3)

56Debug.Assert(leftStream.PartitionCount == rightStream.PartitionCount); 83int partitionCount = leftHashStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (3)

75Debug.Assert(rightStream.PartitionCount == leftStream.PartitionCount); 76int partitionCount = leftStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (3)

58Debug.Assert(leftPartitionedStream.PartitionCount == rightPartitionedStream.PartitionCount); 85int partitionCount = leftHashStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (4)

78Debug.Assert(rightStream.PartitionCount == leftStream.PartitionCount); 85QueryOperator<TLeftInput>.ExecuteAndCollectResults(leftStream, leftStream.PartitionCount, OutputOrdered, preferStriping, settings) 140int partitionCount = leftHashStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (3)

60Debug.Assert(leftStream.PartitionCount == rightStream.PartitionCount); 61int partitionCount = leftStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Inlined\InlinedAggregationOperator.cs (1)

123int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)

108int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)

86int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)

60int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (1)

82int partitionCount = hashStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)

69int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (2)

62ListQueryResults<TSource> listResults = ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings); 74int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (1)

86int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (2)

103int partitionCount = hashStream.PartitionCount; 141int partitionCount = hashStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (1)

91int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)

86int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (2)

63ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings).GetPartitionedStream(); 74int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (1)

58int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (4)

106int partitionCount = inputStream.PartitionCount; 150int partitionCount = inputStream.PartitionCount; 170var outputStream = new PartitionedStream<TOutput, Pair<int, int>>(inputStream.PartitionCount, keyComparer, OrdinalIndexState); 172for (int i = 0; i < inputStream.PartitionCount; i++)

System\Linq\Parallel\QueryOperators\Unary\SelectQueryOperator.cs (2)

53new PartitionedStream<TOutput, TKey>(inputStream.PartitionCount, inputStream.KeyComparer, OrdinalIndexState); 54for (int i = 0; i < inputStream.PartitionCount; i++)

System\Linq\Parallel\QueryOperators\Unary\SingleQueryOperator.cs (1)

58int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (2)

87new PartitionedStream<TInputOutput, TSortKey>(inputStream.PartitionCount, this._comparer, OrdinalIndexState); 89for (int i = 0; i < outputStream.PartitionCount; i++)

System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (2)

95inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings); 107int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (2)

117ListQueryResults<TResult> results = ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.OutputOrdered, preferStriping, settings); 129int partitionCount = inputStream.PartitionCount;

System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (2)

54inputStream.PartitionCount, inputStream.KeyComparer, OrdinalIndexState); 55for (int i = 0; i < inputStream.PartitionCount; i++)

System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (3)

155Debug.Assert(producerDone != null && producerDone.Length == partitions.PartitionCount); 156Debug.Assert(buffers != null && buffers.Length == partitions.PartitionCount); 159int degreeOfParallelism = partitions.PartitionCount;

System\Linq\Parallel\Scheduling\OrderPreservingSpoolingTask.cs (1)

80int maxToRunInParallel = partitions.PartitionCount - 1;

System\Linq\Parallel\Scheduling\SpoolingTask.cs (5)

36Debug.Assert(partitions.PartitionCount == channels.Length); 43int maxToRunInParallel = partitions.PartitionCount - 1; 92Debug.Assert(partitions.PartitionCount == channels.Length); 103for (int i = 0; i < partitions.PartitionCount; i++) 142int maxToRunInParallel = partitions.PartitionCount - 1;

System\Linq\Parallel\Utils\ExchangeUtilities.cs (1)

71Debug.Assert(returnValue.PartitionCount == partitionCount);

System\Linq\Parallel\Utils\Sorting.cs (1)

104int degreeOfParallelism = partitions.PartitionCount;