33 references to ParallelEnumerable
Microsoft.CodeAnalysis.CSharp.CodeStyle (1)
src\Analyzers\CSharp\Analyzers\UseCollectionExpression\UseCollectionExpressionHelpers.cs (1)
42nameof(ParallelEnumerable),
Microsoft.CodeAnalysis.CSharp.Features (1)
src\Analyzers\CSharp\Analyzers\UseCollectionExpression\UseCollectionExpressionHelpers.cs (1)
42nameof(ParallelEnumerable),
Microsoft.ML.FastTree (1)
SumupPerformanceCommand.cs (1)
175ParallelEnumerable.Range(0, arrays.Length).ForAll(i =>
netstandard (1)
netstandard.cs (1)
1039[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Linq.ParallelEnumerable))]
System.Core (1)
System.Core.cs (1)
177[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Linq.ParallelEnumerable))]
System.Linq.Parallel (28)
System\Linq\Parallel\Enumerables\ParallelQuery.cs (1)
104return ParallelEnumerable.Select<TSource, TCastTo>(this, elem => (TCastTo)(object)elem!);
System\Linq\Parallel\Merging\ArrayMergeHelper.cs (1)
62ParallelQuery<int> query = ParallelEnumerable.Range(0, _queryResults.Count);
System\Linq\Parallel\Merging\AsynchronousChannelMergeEnumerator.cs (1)
226Debug.Assert(!ParallelEnumerable.SinglePartitionMode);
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (2)
67Debug.Assert(!ParallelEnumerable.SinglePartitionMode); 103Debug.Assert(!ParallelEnumerable.SinglePartitionMode);
System\Linq\Parallel\Merging\MergeExecutor.cs (1)
67Debug.Assert(!ParallelEnumerable.SinglePartitionMode);
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (4)
360if (!ParallelEnumerable.SinglePartitionMode) { 406if (ParallelEnumerable.SinglePartitionMode) 427Debug.Assert(!ParallelEnumerable.SinglePartitionMode); 481if (!ParallelEnumerable.SinglePartitionMode) {
System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (2)
87if (ParallelEnumerable.SinglePartitionMode) 126Debug.Assert(!ParallelEnumerable.SinglePartitionMode);
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (1)
124Debug.Assert(!ParallelEnumerable.SinglePartitionMode);
System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (1)
455return new Pair<IEnumerable<TElement>, TOrderKey>(ParallelEnumerable.Empty<TElement>(), EmptyValueKey);
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (2)
61if (ParallelEnumerable.SinglePartitionMode) 158if (ParallelEnumerable.SinglePartitionMode)
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (3)
75if (ParallelEnumerable.SinglePartitionMode) 205if (!ParallelEnumerable.SinglePartitionMode) { 217if (!ParallelEnumerable.SinglePartitionMode)
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (2)
75if (ParallelEnumerable.SinglePartitionMode) 217if (!ParallelEnumerable.SinglePartitionMode)
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (2)
111if (ParallelEnumerable.SinglePartitionMode) 228if (!ParallelEnumerable.SinglePartitionMode) {
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (3)
130if (ParallelEnumerable.SinglePartitionMode) 326if (!ParallelEnumerable.SinglePartitionMode) { 334if (!ParallelEnumerable.SinglePartitionMode)
System\Linq\Parallel\Utils\Sorting.cs (1)
203Debug.Assert(!ParallelEnumerable.SinglePartitionMode);
System\Linq\ParallelEnumerable.cs (1)
4111return ParallelEnumerable.Empty<TSource>();