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

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

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

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

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

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

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

101leftHashStream[i], rightHashStream[i], m_comparer, leftHashStream.KeyComparer, cancellationToken); 106new ExceptQueryOperatorEnumerator<TLeftKey>(leftHashStream[i], rightHashStream[i], m_comparer, cancellationToken);

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

115leftHashStream[i], rightHashStream[i], null, m_resultSelector, m_keyComparer, cancellationToken);

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

102leftHashStream[i], rightHashStream[i], m_comparer, leftHashStream.KeyComparer, cancellationToken); 107new IntersectQueryOperatorEnumerator<TLeftKey>(leftHashStream[i], rightHashStream[i], m_comparer, cancellationToken);

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

118leftHashStream[i], rightHashStream[i], m_resultSelector, null, m_keyComparer, cancellationToken);

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

138leftHashStream[i], rightHashStream[i], LeftChild.OutputOrdered, RightChild.OutputOrdered, 152leftHashStream[i], rightHashStream[i], i, m_comparer, cancellationToken);

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

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

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

118outputStream[i] = new AnyAllSearchOperatorEnumerator<TKey>(inputStream[i], m_qualification, m_predicate, i, resultFoundFlag,

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

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

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

106outputStream[i] = new ContainsSearchOperatorEnumerator<TKey>(inputStream[i], m_searchValue, m_comparer, i, resultFoundFlag,

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

76inputStream[i], m_defaultValue, i, partitionCount, sharedEmptyCount, sharedLatch, settings.CancellationState.MergedCancellationToken);

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

95new OrderedDistinctQueryOperatorEnumerator<TKey>(hashStream[i], m_comparer, hashStream.KeyComparer, cancellationToken); 100new DistinctQueryOperatorEnumerator<TKey>(hashStream[i], m_comparer, cancellationToken);

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

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

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

90inputStream[i], m_predicate, operatorState, sharedBarrier,

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

96inputStream[i], m_elementAction, settings.CancellationState.MergedCancellationToken);

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

121hashStream[i], m_keyComparer, cancellationToken); 129hashStream[i], m_keyComparer, m_elementSelector, cancellationToken); 161hashStream[i], m_keySelector, m_keyComparer, orderComparer, cancellationToken); 169hashStream[i], m_keySelector, m_elementSelector, m_keyComparer, orderComparer,

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

117outputStream[i] = new IndexedSelectQueryOperatorEnumerator(inputStreamInt[i], m_selector);

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

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

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

89inputStream[i], m_predicate, operatorState, sharedBarrier, settings.CancellationState.MergedCancellationToken,

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

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

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

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

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

60outputStream[i] = new SelectQueryOperatorEnumerator<TKey>(inputStream[i], m_selector);

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

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

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

121inputStream[i], m_keySelector, m_comparer);

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

120inputStream[i], m_take, sharedIndices, sharredBarrier,

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

150inputStream[i], m_predicate, convertedIndexedPredicate, m_take, operatorState, sharedBarrier,

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

61outputStream[i] = new WhereQueryOperatorEnumerator<TKey>(inputStream[i], m_predicate,

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

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

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

57QueryTask asyncTask = new StopAndGoSpoolingTask<TInputOutput, TIgnoreKey>(i, groupState, partitions[i], channels[i]); 65maxToRunInParallel, groupState, partitions[maxToRunInParallel], channels[maxToRunInParallel]); 109QueryTask asyncTask = new PipelineSpoolingTask<TInputOutput, TIgnoreKey>(i, groupState, partitions[i], channels[i]); 153QueryTask asyncTask = new ForAllSpoolingTask<TInputOutput, TIgnoreKey>(i, groupState, partitions[i]); 160QueryTask syncTask = new ForAllSpoolingTask<TInputOutput, TIgnoreKey>(maxToRunInParallel, groupState, partitions[maxToRunInParallel]);

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

149partitions[i], degreeOfParallelism, i,