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

37inputStream[i], inputStream.PartitionCount, i, hashKeySelector, this, barrier,

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

40inputStream[i], inputStream.PartitionCount, i, keySelector, this,

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

191outputStream[i] = new AssociativeAggregationOperatorEnumerator<TKey>(inputStream[i], this, i, settings.CancellationState.MergedCancellationToken);

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

127outputStream[i] = new ConcatQueryOperatorEnumerator<TLeftKey, TRightKey>(leftStreamInc[i], rightStreamInc[i]);

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

97leftHashStream[i], rightHashStream[i], _comparer, leftHashStream.KeyComparer, cancellationToken); 102new ExceptQueryOperatorEnumerator<TLeftKey>(leftHashStream[i], rightHashStream[i], _comparer, cancellationToken);

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

111rePartitionedRightStream[i], _keyComparer, rePartitionedRightStream.KeyComparer); 127rePartitionedRightStream[i], _keyComparer); 180leftHashStream[i], rightLookupBuilders[i], _resultSelector, outputKeyBuilder, cancellationToken);

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

98leftHashStream[i], rightHashStream[i], _comparer, leftHashStream.KeyComparer, cancellationToken); 103new IntersectQueryOperatorEnumerator<TLeftKey>(leftHashStream[i], rightHashStream[i], _comparer, cancellationToken);

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

148new JoinHashLookupBuilder<TRightInput, TRightKey, TKey>(rightHashStream[i], _keyComparer); 150leftHashStream[i], rightLookupBuilder, _resultSelector, outputKeyBuilder, cancellationToken);

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

134leftHashStream[i], rightHashStream[i], LeftChild.OutputOrdered, RightChild.OutputOrdered, 148leftHashStream[i], rightHashStream[i], _comparer, cancellationToken);

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

129outputStream[i] = CreateEnumerator<TKey>(i, partitionCount, inputStream[i], null, settings.CancellationState.MergedCancellationToken);

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

114outputStream[i] = new AnyAllSearchOperatorEnumerator<TKey>(inputStream[i], _qualification, _predicate, i, resultFoundFlag,

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

93outputStream[i] = new ContainsSearchOperatorEnumerator<TKey>(inputStream[i], _searchValue, _comparer, i, resultFoundFlag,

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

74inputStream[i], _defaultValue, i, partitionCount, sharedEmptyCount, sharedLatch, settings.CancellationState.MergedCancellationToken);

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

91new OrderedDistinctQueryOperatorEnumerator<TKey>(hashStream[i], _comparer, hashStream.KeyComparer, cancellationToken); 96new DistinctQueryOperatorEnumerator<TKey>(hashStream[i], _comparer, cancellationToken);

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

90outputStream[i] = new ElementAtQueryOperatorEnumerator(intKeyStream[i], _index, resultFoundFlag, settings.CancellationState.MergedCancellationToken);

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

88inputStream[i], _predicate, operatorState, sharedBarrier,

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

92inputStream[i], _elementAction, settings.CancellationState.MergedCancellationToken);

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

117hashStream[i], _keyComparer, cancellationToken); 124hashStream[i], _keyComparer, _elementSelector, cancellationToken); 156hashStream[i], _keySelector, _keyComparer, orderComparer, cancellationToken); 163hashStream[i], _keySelector, _elementSelector, _keyComparer, orderComparer,

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

113outputStream[i] = new IndexedSelectQueryOperatorEnumerator(inputStreamInt[i], _selector);

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

107outputStream[i] = new IndexedWhereQueryOperatorEnumerator(inputStreamInt[i], _predicate, settings.CancellationState.MergedCancellationToken);

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

87inputStream[i], _predicate, operatorState, sharedBarrier, settings.CancellationState.MergedCancellationToken,

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

64outputStream[i] = new ReverseQueryOperatorEnumerator<TKey>(inputStream[i], settings.CancellationState.MergedCancellationToken);

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

155outputStream[i] = new SelectManyQueryOperatorEnumerator<TLeftKey>(inputStream[i], this, settings.CancellationState.MergedCancellationToken); 174outputStream[i] = new IndexedSelectManyQueryOperatorEnumerator(inputStream[i], this, settings.CancellationState.MergedCancellationToken);

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

56outputStream[i] = new SelectQueryOperatorEnumerator<TKey>(inputStream[i], _selector);

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

65outputStream[i] = new SingleQueryOperatorEnumerator<TKey>(inputStream[i], _predicate, totalElementCount);

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

92inputStream[i], _keySelector);

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

119inputStream[i], _take, sharedIndices, sharedBarrier,

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

145inputStream[i], _predicate, convertedIndexedPredicate, _take, operatorState, sharedBarrier,

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

57outputStream[i] = new WhereQueryOperatorEnumerator<TKey>(inputStream[i], _predicate,

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

177partitions[i], groupState, consumerWaiting, producerWaiting,

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

52QueryTask asyncTask = new StopAndGoSpoolingTask<TInputOutput, TIgnoreKey>(i, groupState, partitions[i], channels[i]); 60maxToRunInParallel, groupState, partitions[maxToRunInParallel], channels[maxToRunInParallel]); 107QueryTask asyncTask = new PipelineSpoolingTask<TInputOutput, TIgnoreKey>(i, groupState, partitions[i], channels[i]); 150QueryTask asyncTask = new ForAllSpoolingTask<TInputOutput, TIgnoreKey>(i, groupState, partitions[i]); 157QueryTask syncTask = new ForAllSpoolingTask<TInputOutput, TIgnoreKey>(maxToRunInParallel, groupState, partitions[maxToRunInParallel]);

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

147partitions[i], degreeOfParallelism, i,