46 instantiations of ParallelOptions
Microsoft.Build (2)
BackEnd\Components\ProjectCache\ProjectCacheService.cs (1)
33private static readonly ParallelOptions s_parallelOptions = new() { MaxDegreeOfParallelism = Environment.ProcessorCount };
FileMatcher.cs (1)
1016new ParallelOptions { MaxDegreeOfParallelism = dop },
Microsoft.Build.Tasks.Core (2)
FileIO\GetFileHash.cs (1)
81var parallelOptions = new ParallelOptions() { CancellationToken = _cancellationTokenSource.Token };
FileMatcher.cs (1)
1016new ParallelOptions { MaxDegreeOfParallelism = dop },
Microsoft.Build.Utilities.Core (1)
FileMatcher.cs (1)
1016new ParallelOptions { MaxDegreeOfParallelism = dop },
Microsoft.CodeAnalysis (2)
InternalUtilities\RoslynParallel.cs (2)
14internal static readonly ParallelOptions DefaultParallelOptions = new ParallelOptions(); 20? new ParallelOptions { CancellationToken = cancellationToken }
Microsoft.CodeAnalysis.UnitTests (1)
Text\StringTextDecodingTests.cs (1)
220var parallelOptions = new ParallelOptions { MaxDegreeOfParallelism = Environment.ProcessorCount * 2 };
Microsoft.CodeAnalysis.Workspaces (1)
FindSymbols\FindReferences\FindReferencesSearchEngine.cs (1)
51=> new()
Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (2)
src\Compilers\Core\Portable\InternalUtilities\RoslynParallel.cs (2)
14internal static readonly ParallelOptions DefaultParallelOptions = new ParallelOptions(); 20? new ParallelOptions { CancellationToken = cancellationToken }
Microsoft.DotNet.SignTool (1)
src\BatchSignUtil.cs (1)
235ParallelOptions parallelOptions = new ParallelOptions();
Microsoft.Maui.Resizetizer (1)
AsyncTaskExtensions.cs (1)
31 static ParallelOptions ParallelOptions(MauiAsyncTask asyncTask) => new ParallelOptions
Microsoft.ML.Ensemble (1)
Trainer\EnsembleTrainerBase.cs (1)
148new ParallelOptions() { MaxDegreeOfParallelism = Args.TrainParallel ? -1 : 1 },
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)
167new ParallelOptions() { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, 268new ParallelOptions() { MaxDegreeOfParallelism = BlockingThreadPool.NumThreads }, 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 (3)
Standard\MulticlassClassification\PairwiseCouplingTrainer.cs (1)
466var parallelOptions = new ParallelOptions();
Standard\SdcaBinary.cs (2)
364var pOptions = new ParallelOptions { MaxDegreeOfParallelism = numThreads }; 2049var pOptions = new ParallelOptions { MaxDegreeOfParallelism = numThreads };
Microsoft.ML.Sweeper (2)
ConfigRunner.cs (1)
195_parallelOptions = new ParallelOptions { MaxDegreeOfParallelism = options.NumThreads ?? -1 };
SynthConfigRunner.cs (1)
37_parallelOptions = new ParallelOptions { MaxDegreeOfParallelism = options.NumThreads ?? -1 };
Microsoft.ML.Sweeper.Tests (1)
TestSweeper.cs (1)
324var options = new ParallelOptions();
Microsoft.ML.Transforms (1)
Text\WordEmbeddingsExtractor.cs (1)
727=> new ParallelOptions(); // we provide default options and let the Parallel decide
System.Threading.Tasks.Parallel (1)
System\Threading\Tasks\Parallel.cs (1)
139internal static readonly ParallelOptions s_defaultParallelOptions = new ParallelOptions();
82 references to ParallelOptions
Microsoft.Build (1)
BackEnd\Components\ProjectCache\ProjectCacheService.cs (1)
33private static readonly ParallelOptions s_parallelOptions = new() { MaxDegreeOfParallelism = Environment.ProcessorCount };
Microsoft.Build.Tasks.Core (1)
FileIO\GetFileHash.cs (1)
81var parallelOptions = new ParallelOptions() { CancellationToken = _cancellationTokenSource.Token };
Microsoft.CodeAnalysis (3)
InternalUtilities\RoslynParallel.cs (3)
14internal static readonly ParallelOptions DefaultParallelOptions = new ParallelOptions(); 16/// <inheritdoc cref="Parallel.For(int, int, ParallelOptions, Action{int})"/> 19var parallelOptions = cancellationToken.CanBeCanceled
Microsoft.CodeAnalysis.CodeStyle (6)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.cs (2)
33ParallelOptions parallelOptions, 57ParallelOptions parallelOptions,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (4)
75public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 90private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 92private static int EffectiveMaxConcurrencyLevel(ParallelOptions options) 253public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)
Microsoft.CodeAnalysis.UnitTests (1)
Text\StringTextDecodingTests.cs (1)
220var parallelOptions = new ParallelOptions { MaxDegreeOfParallelism = Environment.ProcessorCount * 2 };
Microsoft.CodeAnalysis.Workspaces (7)
FindSymbols\FindReferences\FindReferencesSearchEngine.cs (1)
50private ParallelOptions GetParallelOptions(CancellationToken cancellationToken)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.cs (2)
33ParallelOptions parallelOptions, 57ParallelOptions parallelOptions,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (4)
75public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 90private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 92private static int EffectiveMaxConcurrencyLevel(ParallelOptions options) 253public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)
Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (3)
src\Compilers\Core\Portable\InternalUtilities\RoslynParallel.cs (3)
14internal static readonly ParallelOptions DefaultParallelOptions = new ParallelOptions(); 16/// <inheritdoc cref="Parallel.For(int, int, ParallelOptions, Action{int})"/> 19var parallelOptions = cancellationToken.CanBeCanceled
Microsoft.DotNet.SignTool (1)
src\BatchSignUtil.cs (1)
235ParallelOptions parallelOptions = new ParallelOptions();
Microsoft.Maui.Resizetizer (1)
AsyncTaskExtensions.cs (1)
31 static ParallelOptions ParallelOptions(MauiAsyncTask asyncTask) => new ParallelOptions
Microsoft.ML.StandardTrainers (3)
Standard\MulticlassClassification\PairwiseCouplingTrainer.cs (1)
466var parallelOptions = new ParallelOptions();
Standard\SdcaBinary.cs (2)
364var pOptions = new ParallelOptions { MaxDegreeOfParallelism = numThreads }; 2049var pOptions = new ParallelOptions { MaxDegreeOfParallelism = numThreads };
Microsoft.ML.Sweeper (2)
ConfigRunner.cs (1)
189private readonly ParallelOptions _parallelOptions;
SynthConfigRunner.cs (1)
31private readonly ParallelOptions _parallelOptions;
Microsoft.ML.Sweeper.Tests (1)
TestSweeper.cs (1)
324var options = new ParallelOptions();
Microsoft.ML.Transforms (1)
Text\WordEmbeddingsExtractor.cs (1)
726private static ParallelOptions GetParallelOptions(IHostEnvironment hostEnvironment)
mscorlib (1)
src\libraries\shims\mscorlib\ref\mscorlib.cs (1)
1159[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.ParallelOptions))]
netstandard (1)
netstandard.cs (1)
2111[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.ParallelOptions))]
System.Threading.Tasks.Parallel (49)
System\Threading\Tasks\Parallel.cs (44)
26/// the default TaskScheduler (TaskScheduler.Default). <see cref="ParallelOptions"/> enables 36/// Initializes a new instance of the <see cref="ParallelOptions"/> class. 54/// associated with this <see cref="ParallelOptions"/> instance. Setting this property to null 93/// associated with this <see cref="ParallelOptions"/> instance. 139internal static readonly ParallelOptions s_defaultParallelOptions = new ParallelOptions(); 166/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 191public static void Invoke(ParallelOptions parallelOptions, params Action[] actions) 428/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 450public static ParallelLoopResult For(int fromInclusive, int toExclusive, ParallelOptions parallelOptions, Action<int> body) 465/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 487public static ParallelLoopResult For(long fromInclusive, long toExclusive, ParallelOptions parallelOptions, Action<long> body) 578/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 602public static ParallelLoopResult For(int fromInclusive, int toExclusive, ParallelOptions parallelOptions, Action<int, ParallelLoopState> body) 617/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 641public static ParallelLoopResult For(long fromInclusive, long toExclusive, ParallelOptions parallelOptions, 764/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 808int fromInclusive, int toExclusive, ParallelOptions parallelOptions, 829/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 873long fromInclusive, long toExclusive, ParallelOptions parallelOptions, 916ParallelOptions parallelOptions, 1197/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 1221public static ParallelLoopResult ForEach<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Action<TSource> body) 1267/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 1293public static ParallelLoopResult ForEach<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Action<TSource, ParallelLoopState> body) 1339/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 1365public static ParallelLoopResult ForEach<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Action<TSource, ParallelLoopState, long> body) 1435/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 1481ParallelOptions parallelOptions, Func<TLocal> localInit, 1554/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 1599public static ParallelLoopResult ForEach<TSource, TLocal>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TLocal> localInit, 1637ParallelOptions parallelOptions, 1695ParallelOptions parallelOptions, 1754ParallelOptions parallelOptions, 2123/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 2171ParallelOptions parallelOptions, 2187/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 2237ParallelOptions parallelOptions, 2253/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 2306ParallelOptions parallelOptions, 2328/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 2395ParallelOptions parallelOptions, 2416/// <param name="parallelOptions">A <see cref="System.Threading.Tasks.ParallelOptions">ParallelOptions</see> 2486ParallelOptions parallelOptions, 2508ParallelOptions parallelOptions,
System\Threading\Tasks\Parallel.ForEachAsync.cs (3)
56public static Task ForAsync<T>(T fromInclusive, T toExclusive, ParallelOptions parallelOptions, Func<T, CancellationToken, ValueTask> body) 229public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 384public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)
System\Threading\Tasks\TaskReplicator.cs (2)
124private TaskReplicator(ParallelOptions options, bool stopOnFirstFailure) 130public static void Run<TState>(ReplicatableUserAction<TState> action, ParallelOptions options, bool stopOnFirstFailure)