ParallelOptions

Projects\ProjectLocator.cs (1)

57var parallelOptions = new ParallelOptions

InternalUtilities\RoslynParallel.cs (2)

15internal static readonly ParallelOptions DefaultParallelOptions = new ParallelOptions() { MaxDegreeOfParallelism = Environment.ProcessorCount }; 21? new ParallelOptions { CancellationToken = cancellationToken, MaxDegreeOfParallelism = Environment.ProcessorCount }

Text\StringTextDecodingTests.cs (1)

220var parallelOptions = new ParallelOptions { MaxDegreeOfParallelism = Environment.ProcessorCount * 2 };

FindSymbols\FindReferences\FindReferencesSearchEngine.cs (1)

51=> new()

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

15internal static readonly ParallelOptions DefaultParallelOptions = new ParallelOptions() { MaxDegreeOfParallelism = Environment.ProcessorCount }; 21? new ParallelOptions { CancellationToken = cancellationToken, MaxDegreeOfParallelism = Environment.ProcessorCount }

src\BatchSignUtil.cs (1)

235ParallelOptions parallelOptions = new ParallelOptions();

AsyncTaskExtensions.cs (1)

31 static ParallelOptions ParallelOptions(MauiAsyncTask asyncTask) => new ParallelOptions

Trainer\EnsembleTrainerBase.cs (1)

148new ParallelOptions() { MaxDegreeOfParallelism = Args.TrainParallel ? -1 : 1 },

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);

KMeansPlusPlusTrainer.cs (2)

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

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 };

ConfigRunner.cs (1)

195_parallelOptions = new ParallelOptions { MaxDegreeOfParallelism = options.NumThreads ?? -1 };

SynthConfigRunner.cs (1)

37_parallelOptions = new ParallelOptions { MaxDegreeOfParallelism = options.NumThreads ?? -1 };

TestSweeper.cs (1)

324var options = new ParallelOptions();

Text\WordEmbeddingsExtractor.cs (1)

727=> new ParallelOptions(); // we provide default options and let the Parallel decide

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

141internal static readonly ParallelOptions s_defaultParallelOptions = new ParallelOptions();

Projects\ProjectLocator.cs (1)

57var parallelOptions = new ParallelOptions

src\Dependencies\Threading\ParallelExtensions.cs (2)

19public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 25public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.cs (2)

33public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 39public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (4)

72public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 89private static int EffectiveMaxConcurrencyLevel(ParallelOptions options) 250public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.cs (2)

33public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 39public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (4)

72public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 89private static int EffectiveMaxConcurrencyLevel(ParallelOptions options) 250public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

InternalUtilities\RoslynParallel.cs (3)

15internal static readonly ParallelOptions DefaultParallelOptions = new ParallelOptions() { MaxDegreeOfParallelism = Environment.ProcessorCount }; 17/// <inheritdoc cref="Parallel.For(int, int, ParallelOptions, Action{int})"/> 20var parallelOptions = cancellationToken.CanBeCanceled

src\Dependencies\Threading\ParallelExtensions.cs (2)

33public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 39public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (4)

72public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 89private static int EffectiveMaxConcurrencyLevel(ParallelOptions options) 250public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.cs (2)

33public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 39public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (4)

72public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 89private static int EffectiveMaxConcurrencyLevel(ParallelOptions options) 250public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.cs (2)

33public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 39public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (4)

72public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 89private static int EffectiveMaxConcurrencyLevel(ParallelOptions options) 250public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.cs (2)

33public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 39public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (4)

72public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 89private static int EffectiveMaxConcurrencyLevel(ParallelOptions options) 250public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.cs (2)

33public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 39public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (4)

72public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 89private static int EffectiveMaxConcurrencyLevel(ParallelOptions options) 250public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.cs (2)

33public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 39public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (4)

72public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 89private static int EffectiveMaxConcurrencyLevel(ParallelOptions options) 250public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.cs (2)

33public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 39public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (4)

72public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 89private static int EffectiveMaxConcurrencyLevel(ParallelOptions options) 250public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.cs (2)

33public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 39public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (4)

72public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 89private static int EffectiveMaxConcurrencyLevel(ParallelOptions options) 250public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

ParallelExtensions.cs (2)

19public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 25public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

Text\StringTextDecodingTests.cs (1)

220var parallelOptions = new ParallelOptions { MaxDegreeOfParallelism = Environment.ProcessorCount * 2 };

FindSymbols\FindReferences\FindReferencesSearchEngine.cs (1)

50private ParallelOptions GetParallelOptions(CancellationToken cancellationToken)

src\Dependencies\Threading\ParallelExtensions.cs (2)

19public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 25public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

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

15internal static readonly ParallelOptions DefaultParallelOptions = new ParallelOptions() { MaxDegreeOfParallelism = Environment.ProcessorCount }; 17/// <inheritdoc cref="Parallel.For(int, int, ParallelOptions, Action{int})"/> 20var parallelOptions = cancellationToken.CanBeCanceled

src\BatchSignUtil.cs (1)

235ParallelOptions parallelOptions = new ParallelOptions();

AsyncTaskExtensions.cs (1)

31 static ParallelOptions ParallelOptions(MauiAsyncTask asyncTask) => new ParallelOptions

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 };

ConfigRunner.cs (1)

189private readonly ParallelOptions _parallelOptions;

SynthConfigRunner.cs (1)

31private readonly ParallelOptions _parallelOptions;

TestSweeper.cs (1)

324var options = new ParallelOptions();

Text\WordEmbeddingsExtractor.cs (1)

726private static ParallelOptions GetParallelOptions(IHostEnvironment hostEnvironment)

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

1159[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.ParallelOptions))]

netstandard.cs (1)

2111[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.ParallelOptions))]

src\Dependencies\Threading\ParallelExtensions.cs (2)

33public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 39public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (4)

72public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 89private static int EffectiveMaxConcurrencyLevel(ParallelOptions options) 250public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

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

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)

125private TaskReplicator(ParallelOptions options, bool stopOnFirstFailure) 131public static void Run<TState>(ReplicatableUserAction<TState> action, ParallelOptions options, bool stopOnFirstFailure)

src\Dependencies\Threading\ParallelExtensions.cs (2)

19public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 25public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.cs (2)

33public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 39public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (4)

72public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body) 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 89private static int EffectiveMaxConcurrencyLevel(ParallelOptions options) 250public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)