145 references to Parallel
aspire (4)
Commands\AddCommand.cs (1)
145await Parallel.ForEachAsync(channels, cancellationToken, async (channel, ct) =>
Commands\InitCommand.cs (1)
758await Parallel.ForEachAsync(channels, cancellationToken, async (channel, ct) =>
Projects\ProjectLocator.cs (1)
115await Parallel.ForEachAsync(candidatesWithHandlers, parallelOptions, async (candidate, ct) =>
Templating\DotNetTemplateFactory.cs (1)
685await Parallel.ForEachAsync(channels, cancellationToken, async (channel, ct) =>
dotnet (2)
Commands\Test\MTP\MSBuildUtility.cs (1)
266Parallel.ForEach(
ReleasePropertyProjectLocator.cs (1)
162Parallel.ForEach(sln.SolutionProjects.AsEnumerable(), (project, state) =>
GenerateDocumentationAndConfigFiles (7)
src\roslyn\src\Dependencies\Threading\ParallelExtensions.cs (4)
17=> Parallel.ForEachAsync(source, cancellationToken, body); 20=> Parallel.ForEachAsync(source, parallelOptions, body); 23=> Parallel.ForEachAsync(source, cancellationToken, body); 26=> Parallel.ForEachAsync(source, parallelOptions, body);
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
234Parallel.ForEachAsync( 296Parallel.ForEachAsync(
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Workspace\Core\Simplification\AbstractSimplificationService.cs (1)
175await Parallel.ForEachAsync(
ILCompiler.Compiler (1)
Compiler\ILScanner.cs (1)
99Parallel.ForEach(
ILCompiler.RyuJit (1)
Compiler\RyuJitCompilation.cs (1)
166Parallel.ForEach(
Microsoft.Build (3)
BackEnd\Components\Communications\NodeProviderOutOfProcBase.cs (1)
286Parallel.For(nextNodeId, nextNodeId + numberOfNodesToCreate, (nodeId) =>
BackEnd\Components\ProjectCache\ProjectCacheService.cs (2)
113Parallel.ForEach( 148Parallel.ForEach(
Microsoft.Build.Framework (1)
Utilities\FileMatcher.cs (1)
1024Parallel.ForEach(
Microsoft.Build.Tasks.Core (5)
FileIO\GetFileHash.cs (1)
88Parallel.For(0, Files.Length, parallelOptions, index =>
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(
Microsoft.CodeAnalysis (2)
InternalUtilities\RoslynParallel.cs (2)
17/// <inheritdoc cref="Parallel.For(int, int, ParallelOptions, Action{int})"/> 24return Parallel.For(fromInclusive, toExclusive, parallelOptions, errorHandlingBody);
Microsoft.CodeAnalysis.Analyzers (4)
src\roslyn\src\Dependencies\Threading\ParallelExtensions.cs (1)
28extension(Parallel)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
234Parallel.ForEachAsync( 296Parallel.ForEachAsync(
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Workspace\Core\Simplification\AbstractSimplificationService.cs (1)
175await Parallel.ForEachAsync(
Microsoft.CodeAnalysis.AnalyzerUtilities (3)
src\roslyn\src\Dependencies\Threading\ParallelExtensions.cs (1)
28extension(Parallel)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
234Parallel.ForEachAsync( 296Parallel.ForEachAsync(
Microsoft.CodeAnalysis.CodeStyle (3)
src\roslyn\src\Dependencies\Threading\ParallelExtensions.cs (1)
28extension(Parallel)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
234Parallel.ForEachAsync( 296Parallel.ForEachAsync(
Microsoft.CodeAnalysis.CodeStyle.Fixes (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Workspace\Core\Simplification\AbstractSimplificationService.cs (1)
175await Parallel.ForEachAsync(
Microsoft.CodeAnalysis.Features (7)
CodeFixes\Suppression\AbstractSuppressionBatchFixAllProvider.cs (1)
120await Parallel.ForEachAsync(
IntroduceParameter\AbstractIntroduceParameterCodeRefactoringProvider.cs (1)
265await Parallel.ForEachAsync(
NavigateTo\AbstractNavigateToSearchService.CachedDocumentSearch.cs (1)
153await Parallel.ForEachAsync(
NavigateTo\AbstractNavigateToSearchService.GeneratedDocumentSearch.cs (1)
83await Parallel.ForEachAsync(
NavigateTo\AbstractNavigateToSearchService.NormalSearch.cs (1)
223await Parallel.ForEachAsync(
NavigateTo\NavigateToSearcher.cs (1)
370await Parallel.ForEachAsync(
ValueTracking\ValueTracker.OperationCollector.cs (1)
189await Parallel.ForEachAsync(
Microsoft.CodeAnalysis.ResxSourceGenerator (3)
src\roslyn\src\Dependencies\Threading\ParallelExtensions.cs (1)
28extension(Parallel)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
234Parallel.ForEachAsync( 296Parallel.ForEachAsync(
Microsoft.CodeAnalysis.Workspaces (13)
CodeFixes\FixAllOccurrences\DocumentBasedFixAllProvider.cs (1)
84await Parallel.ForEachAsync(
CodeRefactorings\FixAllOccurences\DocumentBasedRefactorAllProvider.cs (1)
94await Parallel.ForEachAsync(
FindSymbols\FindLiterals\FindLiteralsSearchEngine.cs (1)
90await Parallel.ForEachAsync(
FindSymbols\FindReferences\FindReferencesSearchEngine.cs (3)
117await Parallel.ForEachAsync( 250await Parallel.ForEachAsync( 301await Parallel.ForEachAsync(
src\roslyn\src\Dependencies\Threading\ParallelExtensions.cs (4)
17=> Parallel.ForEachAsync(source, cancellationToken, body); 20=> Parallel.ForEachAsync(source, parallelOptions, body); 23=> Parallel.ForEachAsync(source, cancellationToken, body); 26=> Parallel.ForEachAsync(source, parallelOptions, body);
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
234Parallel.ForEachAsync( 296Parallel.ForEachAsync(
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Workspace\Core\Simplification\AbstractSimplificationService.cs (1)
175await Parallel.ForEachAsync(
Microsoft.DotNet.Build.Tasks.Packaging (3)
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));
Microsoft.DotNet.SourceBuild.Tasks (1)
src\UsageReport\WritePackageUsageData.cs (1)
178Parallel.ForEach(
Microsoft.Extensions.AI.Evaluation.Integration.Tests (1)
QualityEvaluatorTests.cs (1)
116await Parallel.ForAsync(1, 6, async (i, cancellationToken) =>
Microsoft.Extensions.Compliance.Testing.Tests (1)
FakeRedactorTests.cs (1)
84Parallel.ForEach(iterations, iteration =>
Microsoft.Extensions.Http.Resilience.Tests (1)
Internal\RandomizerTest.cs (1)
29Parallel.Invoke(actions);
Microsoft.Extensions.Telemetry.Tests (2)
Logging\ExtendedLoggerTests.cs (2)
965Parallel.For(0, 1000, _ => 1006Parallel.For(0, 100, i =>
Microsoft.Maui.Resizetizer (1)
AsyncTaskExtensions.cs (1)
16 return Parallel.ForEach(source, ParallelOptions(asyncTask),
Microsoft.ML.Core (3)
Utilities\MatrixTransposeOps.cs (3)
95Parallel.ForEach(ijenum, ij => 147Parallel.ForEach(ijenum, ij => 200Parallel.ForEach(ijenum, ij =>
Microsoft.ML.Ensemble (6)
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 =>
Microsoft.ML.FastTree (22)
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);
Microsoft.ML.KMeansClustering (2)
KMeansPlusPlusTrainer.cs (2)
1394Parallel.Invoke(new ParallelOptions() 1741Parallel.Invoke(new ParallelOptions()
Microsoft.ML.StandardTrainers (8)
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));
Microsoft.ML.Sweeper (1)
ConfigRunner.cs (1)
202Parallel.For(0, sweeps.Length, _parallelOptions, j =>
Microsoft.ML.Sweeper.Tests (1)
TestSweeper.cs (1)
331var r = Task.Run(() => Parallel.For(0, sweeps, options, async (int i) =>
Microsoft.ML.TestFramework (2)
CopyAction.cs (2)
16Parallel.ForEach(directories, dirPath => 23Parallel.ForEach(files, oldPath =>
Microsoft.ML.Tests (1)
Scenarios\Api\Estimators\MultithreadedPrediction.cs (1)
46Parallel.ForEach(testData, (input) =>
Microsoft.ML.Transforms (1)
Text\WordEmbeddingsExtractor.cs (1)
682Parallel.ForEach(File.ReadLines(_modelFileNameWithPath).Skip(skippedLinesCount), GetParallelOptions(hostEnvironment),
Microsoft.NET.Sdk.BlazorWebAssembly.Tasks (2)
GenerateServiceWorkerAssetsManifest.cs (1)
37Parallel.For(0, assets.Length, i =>
GZipCompress.cs (1)
33Parallel.For(0, FilesToCompress.Length, i =>
Microsoft.NET.Sdk.BlazorWebAssembly.Tool (1)
Program.cs (1)
46Parallel.For(0, s.Count, i =>
Microsoft.NET.Sdk.StaticWebAssets.Tasks (3)
Compression\GZipCompress.cs (1)
30Parallel.For(0, FilesToCompress.Length, i =>
DefineStaticWebAssetEndpoints.cs (1)
34Parallel.For(
ScopedCss\RewriteCss.cs (1)
38Parallel.For(0, FilesToTransform.Length, i =>
Microsoft.NET.Sdk.StaticWebAssets.Tool (1)
Program.cs (1)
46Parallel.For(0, s.Count, i =>
mscorlib (1)
src\runtime\src\libraries\shims\mscorlib\ref\mscorlib.cs (1)
1156[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Parallel))]
netstandard (1)
netstandard.cs (1)
2108[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Parallel))]
NuGet.Build.Tasks (1)
BuildTasksUtility.cs (1)
244Parallel.ForEach(dependencyGraphSpec.Projects.Where(i => !DoesProjectSupportRestore(i)), project =>
NuGet.Build.Tasks.Console (1)
MSBuildStaticGraphRestore.cs (1)
978Parallel.ForEach(projects, new ParallelOptions { MaxDegreeOfParallelism = Environment.ProcessorCount }, project =>
NuGet.CommandLine.XPlat (1)
Commands\Package\Update\PackageUpdateCommandRunner.cs (1)
366await Parallel.ForEachAsync(dgSpec.Restore, parallelOptions, async (projectPath, ct) =>
NuGet.Commands (1)
RestoreCommand\RequestFactory\DependencyGraphSpecRequestProvider.cs (1)
97Parallel.ForEach(dgFile.Restore.ToArray(), parallelOptions, projectNameToRestore =>
Roslyn.Diagnostics.Analyzers (4)
src\roslyn\src\Dependencies\Threading\ParallelExtensions.cs (1)
28extension(Parallel)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
234Parallel.ForEachAsync( 296Parallel.ForEachAsync(
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Workspace\Core\Simplification\AbstractSimplificationService.cs (1)
175await Parallel.ForEachAsync(
rzc (1)
GenerateCommand.cs (1)
375Parallel.For(0, outputs.Length, new ParallelOptions() { MaxDegreeOfParallelism = Debugger.IsAttached ? 1 : 4 }, i =>
System.Threading.Tasks.Parallel (10)
System\Threading\Tasks\Parallel.cs (4)
24/// <see cref="System.Threading.Tasks.Parallel">Parallel</see> class. 73/// cref="System.Threading.Tasks.Parallel">Parallel</see> method calls that are passed this 99/// to a <see cref="System.Threading.Tasks.Parallel">Parallel</see> method enables the operation to be 129/// 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;