6 writes to CancellationToken
aspire (1)
Projects\ProjectLocator.cs (1)
69CancellationToken = cancellationToken,
Microsoft.Build.Tasks.Core (1)
FileIO\GetFileHash.cs (1)
85var parallelOptions = new ParallelOptions() { CancellationToken = _cancellationTokenSource.Token };
Microsoft.CodeAnalysis (1)
InternalUtilities\RoslynParallel.cs (1)
21? new ParallelOptions { CancellationToken = cancellationToken, MaxDegreeOfParallelism = Environment.ProcessorCount }
Microsoft.CodeAnalysis.Workspaces (1)
FindSymbols\FindReferences\FindReferencesSearchEngine.cs (1)
53CancellationToken = cancellationToken,
Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (1)
src\Compilers\Core\Portable\InternalUtilities\RoslynParallel.cs (1)
21? new ParallelOptions { CancellationToken = cancellationToken, MaxDegreeOfParallelism = Environment.ProcessorCount }
Microsoft.Maui.Resizetizer (1)
AsyncTaskExtensions.cs (1)
33 CancellationToken = asyncTask.CancellationToken,
46 references to CancellationToken
Metrics (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (2)
81return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body); 261return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body);
Metrics.Legacy (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (2)
81return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body); 261return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body);
Microsoft.CodeAnalysis.Analyzers (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (2)
81return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body); 261return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body);
Microsoft.CodeAnalysis.AnalyzerUtilities (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (2)
81return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body); 261return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body);
Microsoft.CodeAnalysis.BannedApiAnalyzers (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (2)
81return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body); 261return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body);
Microsoft.CodeAnalysis.CodeStyle (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (2)
81return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body); 261return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body);
Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (2)
81return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body); 261return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body);
Microsoft.CodeAnalysis.PublicApiAnalyzers (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (2)
81return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body); 261return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body);
Microsoft.CodeAnalysis.ResxSourceGenerator (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (2)
81return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body); 261return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body);
Roslyn.Diagnostics.Analyzers (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (2)
81return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body); 261return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body);
System.Threading.Tasks.Parallel (24)
System\Threading\Tasks\Parallel.cs (21)
43/// be employed. <see cref="CancellationToken"/> is initialized to a non-cancelable token, 204parallelOptions.CancellationToken.ThrowIfCancellationRequested(); 284parallelOptions.CancellationToken.ThrowIfCancellationRequested(); 322ThrowSingleCancellationExceptionOrOtherException(exceptionQ, parallelOptions.CancellationToken, 332parallelOptions.CancellationToken.ThrowIfCancellationRequested(); 337tasks[i] = Task.Factory.StartNew(actionsCopy[i], parallelOptions.CancellationToken, TaskCreationOptions.None, 340tasks[0] = new Task(actionsCopy[0], parallelOptions.CancellationToken, TaskCreationOptions.None); 353ThrowSingleCancellationExceptionOrOtherException(aggExp.InnerExceptions, parallelOptions.CancellationToken, aggExp); 940parallelOptions.CancellationToken.ThrowIfCancellationRequested(); 953CancellationTokenRegistration ctr = (!parallelOptions.CancellationToken.CanBeCanceled) 955: parallelOptions.CancellationToken.UnsafeRegister((o) => 958oce = new OperationCanceledException(parallelOptions.CancellationToken); 1115if (parallelOptions.CancellationToken.CanBeCanceled) 1126ThrowSingleCancellationExceptionOrOtherException(aggExp.InnerExceptions, parallelOptions.CancellationToken, aggExp); 1647parallelOptions.CancellationToken.ThrowIfCancellationRequested(); 2528parallelOptions.CancellationToken.ThrowIfCancellationRequested(); 2552CancellationTokenRegistration ctr = (!parallelOptions.CancellationToken.CanBeCanceled) 2554: parallelOptions.CancellationToken.UnsafeRegister((o) => 2557oce = new OperationCanceledException(parallelOptions.CancellationToken); 2751if (parallelOptions.CancellationToken.CanBeCanceled) 2762ThrowSingleCancellationExceptionOrOtherException(aggExp.InnerExceptions, parallelOptions.CancellationToken, aggExp);
System\Threading\Tasks\Parallel.ForEachAsync.cs (3)
64return ForAsync(fromInclusive, toExclusive, parallelOptions.EffectiveMaxConcurrencyLevel, parallelOptions.EffectiveTaskScheduler, parallelOptions.CancellationToken, body); 235return ForEachAsync(source, parallelOptions.EffectiveMaxConcurrencyLevel, parallelOptions.EffectiveTaskScheduler, parallelOptions.CancellationToken, body); 390return ForEachAsync(source, parallelOptions.EffectiveMaxConcurrencyLevel, parallelOptions.EffectiveTaskScheduler, parallelOptions.CancellationToken, body);
Text.Analyzers (2)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (2)
81return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body); 261return ForEachAsync(source, EffectiveMaxConcurrencyLevel(parallelOptions), EffectiveTaskScheduler(parallelOptions), parallelOptions.CancellationToken, body);