2 writes to CancellationToken
Microsoft.Build.Tasks.Core (1)
FileIO\GetFileHash.cs (1)
81
var parallelOptions = new ParallelOptions() {
CancellationToken
= _cancellationTokenSource.Token };
MonoTargetsTasks (1)
EmitBundleTask\EmitBundleBase.cs (1)
163
Parallel.For(0, remainingDestinationFilesToBundle.Length, new ParallelOptions { MaxDegreeOfParallelism = allowedParallelism,
CancellationToken
= BuildTaskCancelled.Token }, (i, state) =>
24 references to CancellationToken
System.Threading.Tasks.Parallel (24)
System\Threading\Tasks\Parallel.cs (21)
41
/// be employed. <see cref="
CancellationToken
"/> is initialized to a non-cancelable token,
202
parallelOptions.
CancellationToken
.ThrowIfCancellationRequested();
287
parallelOptions.
CancellationToken
.ThrowIfCancellationRequested();
325
ThrowSingleCancellationExceptionOrOtherException(exceptionQ, parallelOptions.
CancellationToken
,
335
parallelOptions.
CancellationToken
.ThrowIfCancellationRequested();
340
tasks[i] = Task.Factory.StartNew(actionsCopy[i], parallelOptions.
CancellationToken
, TaskCreationOptions.None,
343
tasks[0] = new Task(actionsCopy[0], parallelOptions.
CancellationToken
, TaskCreationOptions.None);
358
ThrowSingleCancellationExceptionOrOtherException(aggExp.InnerExceptions, parallelOptions.
CancellationToken
, aggExp);
945
parallelOptions.
CancellationToken
.ThrowIfCancellationRequested();
958
CancellationTokenRegistration ctr = (!parallelOptions.
CancellationToken
.CanBeCanceled)
960
: parallelOptions.
CancellationToken
.UnsafeRegister((o) =>
963
oce = new OperationCanceledException(parallelOptions.
CancellationToken
);
1120
if (parallelOptions.
CancellationToken
.CanBeCanceled)
1131
ThrowSingleCancellationExceptionOrOtherException(aggExp.InnerExceptions, parallelOptions.
CancellationToken
, aggExp);
1652
parallelOptions.
CancellationToken
.ThrowIfCancellationRequested();
2533
parallelOptions.
CancellationToken
.ThrowIfCancellationRequested();
2557
CancellationTokenRegistration ctr = (!parallelOptions.
CancellationToken
.CanBeCanceled)
2559
: parallelOptions.
CancellationToken
.UnsafeRegister((o) =>
2562
oce = new OperationCanceledException(parallelOptions.
CancellationToken
);
2757
if (parallelOptions.
CancellationToken
.CanBeCanceled)
2768
ThrowSingleCancellationExceptionOrOtherException(aggExp.InnerExceptions, parallelOptions.
CancellationToken
, aggExp);
System\Threading\Tasks\Parallel.ForEachAsync.cs (3)
64
return ForAsync(fromInclusive, toExclusive, parallelOptions.EffectiveMaxConcurrencyLevel, parallelOptions.EffectiveTaskScheduler, parallelOptions.
CancellationToken
, body);
259
return ForEachAsync(source, parallelOptions.EffectiveMaxConcurrencyLevel, parallelOptions.EffectiveTaskScheduler, parallelOptions.
CancellationToken
, body);
414
return ForEachAsync(source, parallelOptions.EffectiveMaxConcurrencyLevel, parallelOptions.EffectiveTaskScheduler, parallelOptions.
CancellationToken
, body);