Parallel

Program.cs (1)

192Parallel.ForEach(projects.SelectMany(project => project.Documents), document =>

ConnectionLimitTests.cs (1)

201Parallel.For(0, count, async i =>

Integration\OpenApiDocumentConcurrentRequestTests.cs (1)

20await Parallel.ForAsync(0, 150, async (_, ctx) =>

ResourceCounterTests.cs (2)

37Parallel.For(0, max, i => 42Parallel.For(0, 10, i =>

SchedulerBenchmark.cs (1)

80Parallel.For(0, OuterLoopCount, () => schedulers, _parallelAction, (s) => { });

BackEnd\Components\Communications\NodeProviderOutOfProcBase.cs (1)

240Parallel.For(nextNodeId, nextNodeId + numberOfNodesToCreate, (nodeId) =>

BackEnd\Components\ProjectCache\ProjectCacheService.cs (2)

110Parallel.ForEach( 146Parallel.ForEach(

FileMatcher.cs (1)

1014Parallel.ForEach(

BackEnd\SdkResolverService_Tests.cs (1)

623Parallel.For(

FileIO\GetFileHash.cs (1)

84Parallel.For(0, Files.Length, parallelOptions, index =>

FileMatcher.cs (1)

1014Parallel.ForEach(

GetSDKReferenceFiles.cs (4)

1037Parallel.ForEach(sdkManifestReferences, reference => { references.TryAdd(reference, GetSDKReferenceInfo(reference)); }); 1046Parallel.ForEach( 1053Parallel.ForEach(files, filePath => { references.TryAdd(filePath, GetSDKReferenceInfo(filePath)); }); 1063Parallel.ForEach(

FileMatcher.cs (1)

1014Parallel.ForEach(

InternalUtilities\RoslynParallel.cs (2)

16/// <inheritdoc cref="Parallel.For(int, int, ParallelOptions, Action{int})"/> 23return Parallel.For(fromInclusive, toExclusive, parallelOptions, errorHandlingBody);

CodeGen\CodeGenCapturing.cs (1)

444Parallel.ForEach(Partitioner.Create(0, methods.Count, PartitionSize), (range, state) =>

Semantics\PrimaryConstructorTests.cs (1)

14596System.Threading.Tasks.Parallel.For(0, 100, (int i) => comp.VerifyDiagnostics());

Semantics\ConstantTests.cs (6)

3004Parallel.ForEach(types, t => t.ForceComplete(null, filter: null, default(CancellationToken))); 3036Parallel.ForEach(types, t => t.ForceComplete(null, filter: null, default(CancellationToken))); 3091Parallel.ForEach(types, t => t.ForceComplete(null, filter: null, default(CancellationToken))); 3123Parallel.ForEach(types, t => t.ForceComplete(null, filter: null, default(CancellationToken))); 3181Parallel.ForEach(types, t => t.ForceComplete(null, filter: null, default(CancellationToken))); 3216Parallel.ForEach(types, t => t.ForceComplete(null, filter: null, default(CancellationToken)));

Compilation\SemanticModelGetDeclaredSymbolAPITests.cs (2)

4538var result = Parallel.For(0, 100, i => 4574var result = Parallel.For(0, 100, i =>

Symbols\IndexerTests.cs (2)

2166var loopResult = Parallel.ForEach(compilation.GlobalNamespace.GetTypeMembers(), type => 2197var loopResult = Parallel.ForEach(compilation.GlobalNamespace.GetTypeMembers(), type =>

Symbols\Source\CompletionTests.cs (2)

123Parallel.For(0, Math.Max(1, Environment.ProcessorCount - 1), t => 136Parallel.Invoke(reader, writers);

Text\StringTextDecodingTests.cs (1)

221Parallel.For(0, 500, parallelOptions, i =>

src\Compilers\Core\Portable\InternalUtilities\RoslynParallel.cs (2)

16/// <inheritdoc cref="Parallel.For(int, int, ParallelOptions, Action{int})"/> 23return Parallel.For(fromInclusive, toExclusive, parallelOptions, errorHandlingBody);

NuGetUtility.cs (1)

28Parallel.ForEach(enabledSources, (packageSource) =>

UpdatePackageIndex.cs (1)

190Parallel.ForEach(index.Packages, (package) =>

ValidateHarvestVersionIsLatestForRelease.cs (1)

29Parallel.ForEach(PackageReports, (reportPath) => ValidateHarvestVersionForReport(reportPath.ItemSpec));

CreateVisualStudioWorkload.wix.cs (7)

15using Parallel = System.Threading.Tasks.Parallel; 335_ = Parallel.ForEach(buildData.Values, data => 342_ = Parallel.ForEach(data.FeatureBands.Keys, platform => 432_ = Parallel.ForEach(manifestMsisToBuild, msi => 468_ = Parallel.ForEach(swixComponents, swixComponent => 485_ = Parallel.ForEach(swixPackageGroups, swixPackageGroup => 505_ = Parallel.ForEach(source, body);

CreateVisualStudioWorkloadSet.wix.cs (2)

10using Parallel = System.Threading.Tasks.Parallel; 68_ = Parallel.ForEach(workloadSetMsisToBuild, msi =>

src\BatchSignUtil.cs (1)

260Parallel.ForEach(smallRepackList, parallelOptions, file =>

src\UsageReport\WritePackageUsageData.cs (1)

178Parallel.ForEach(

FakeRedactorTests.cs (1)

84Parallel.ForEach(iterations, iteration =>

Internal\RandomizerTest.cs (1)

29Parallel.Invoke(actions);

AsyncTaskExtensions.cs (1)

16 return Parallel.ForEach(source, ParallelOptions(asyncTask),

Utilities\MatrixTransposeOps.cs (3)

95Parallel.ForEach(ijenum, ij => 147Parallel.ForEach(ijenum, ij => 200Parallel.ForEach(ijenum, ij =>

OutputCombiners\BaseStacking.cs (1)

183Parallel.For(0, maps.Length, i =>

Trainer\EnsembleDistributionModelParameters.cs (2)

157Parallel.For(0, maps.Length, i => 195Parallel.For(0, maps.Length, i =>

Trainer\EnsembleModelParameters.cs (1)

149Parallel.For(0, maps.Length, i =>

Trainer\EnsembleTrainerBase.cs (1)

147Parallel.ForEach(_subsetSelector.GetSubsets(batch, Host.Rand),

Trainer\Multiclass\EnsembleMulticlassModelParameters.cs (1)

134Parallel.For(0, maps.Length, i =>

Dataset\Dataset.cs (2)

267Parallel.For(0, NumFlocks, new ParallelOptions { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, 317Parallel.For(0, NumFlocks, new ParallelOptions { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads },

GamClassification.cs (1)

134Parallel.Invoke(new ParallelOptions { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, actions);

Training\Applications\ObjectiveFunction.cs (1)

79Parallel.Invoke(new ParallelOptions() { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, actions);

Training\DcgCalculator.cs (4)

166Parallel.ForEach(Enumerable.Range(0, dataset.NumQueries).Where(query => maxDCG3[query] > 0), 267Parallel.ForEach(Enumerable.Range(0, dataset.NumQueries).Where(query => maxDCG1[query] > 0), 383Parallel.Invoke(new ParallelOptions() { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, actions); 521Parallel.Invoke(new ParallelOptions() { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, actions);

Training\DocumentPartitioning.cs (2)

97Parallel.Invoke(new ParallelOptions { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, actions); 129Parallel.Invoke(new ParallelOptions { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, actions);

Training\ScoreTracker.cs (3)

105Parallel.For(0, tree.NumLeaves, new ParallelOptions { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, (leaf) => 194Parallel.Invoke(new ParallelOptions { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, actions); 203Parallel.For(0, tree.NumLeaves, new ParallelOptions { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads },

Training\Test.cs (3)

565Parallel.Invoke(new ParallelOptions() { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, actions); 640Parallel.Invoke(new ParallelOptions() { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, actions); 698Parallel.Invoke(new ParallelOptions() { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, actions);

Training\WinLossCalculator.cs (1)

63Parallel.Invoke(new ParallelOptions { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, actions);

TreeEnsemble\InternalRegressionTree.cs (3)

1395Parallel.Invoke(new ParallelOptions { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, actions); 1420Parallel.Invoke(new ParallelOptions { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, actions); 1443Parallel.Invoke(new ParallelOptions { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, actions);

TreeEnsemble\InternalTreeEnsemble.cs (1)

308Parallel.Invoke(new ParallelOptions { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, actions);

Utils\ThreadTaskManager.cs (1)

59Parallel.Invoke(new ParallelOptions() { MaxDegreeOfParallelism = _num }, _actions);

KMeansPlusPlusTrainer.cs (2)

1394Parallel.Invoke(new ParallelOptions() 1741Parallel.Invoke(new ParallelOptions()

Standard\LogisticRegression\LbfgsPredictorBase.cs (1)

816Parallel.For(0, _numChunks,

Standard\MulticlassClassification\OneVersusAllTrainer.cs (3)

636Parallel.For(0, maps.Length, i => maps[i](in tmp, ref buffer[i])); 729Parallel.For(0, maps.Length, 885Parallel.For(0, maps.Length, i => maps[i](in tmp, ref buffer[i]));

Standard\MulticlassClassification\PairwiseCouplingTrainer.cs (1)

475Parallel.For(0, maps.Length, parallelOptions, i =>

Standard\SdcaBinary.cs (3)

638Parallel.For(0, checkFrequency, pOptions, 652Parallel.For(0, residue, pOptions, 2193Parallel.For(0, _options.NumberOfIterations, pOptions, i => trainingTasks[i](rands[i], pch));

ConfigRunner.cs (1)

202Parallel.For(0, sweeps.Length, _parallelOptions, j =>

TestSweeper.cs (1)

331var r = Task.Run(() => Parallel.For(0, sweeps, options, async (int i) =>

CopyAction.cs (2)

16Parallel.ForEach(directories, dirPath => 23Parallel.ForEach(files, oldPath =>

Scenarios\Api\Estimators\MultithreadedPrediction.cs (1)

46Parallel.ForEach(testData, (input) =>

Text\WordEmbeddingsExtractor.cs (1)

682Parallel.ForEach(File.ReadLines(_modelFileNameWithPath).Skip(skippedLinesCount), GetParallelOptions(hostEnvironment),

src\libraries\shims\mscorlib\ref\mscorlib.cs (1)

1156[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Parallel))]

netstandard.cs (1)

2108[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Parallel))]

TestDiscovery.cs (1)

32Parallel.ForEach(assemblies, assembly =>

System\Threading\Tasks\Parallel.cs (4)

22/// <see cref="System.Threading.Tasks.Parallel">Parallel</see> class. 71/// cref="System.Threading.Tasks.Parallel">Parallel</see> method calls that are passed this 97/// to a <see cref="System.Threading.Tasks.Parallel">Parallel</see> method enables the operation to be 127/// The <see cref="System.Threading.Tasks.Parallel"/> class provides library-based data parallel replacements

System\Threading\Tasks\ParallelLoopState.cs (5)

20/// Enables iterations of <see cref="System.Threading.Tasks.Parallel"/> loops to interact with 55/// when one throws an exception, or when the loop is canceled, the <see cref="Parallel"/> class will proactively 121/// Communicates that the <see cref="Parallel"/> loop should cease execution at the system's earliest 154/// Communicates that the <see cref="Parallel"/> loop should cease execution at the system's earliest 413/// Provides completion status on the execution of a <see cref="Parallel"/> loop.

System\Threading\Tasks\ParallelRangeManager.cs (1)

80_nMaxIncrementValue = Parallel.DEFAULT_LOOP_STRIDE * nStep;