1 instantiation of CancellationTokenRegistration
System.Private.CoreLib (1)
src\libraries\System.Private.CoreLib\src\System\Threading\CancellationTokenSource.cs (1)
680return new CancellationTokenRegistration(id, node);
248 references to CancellationTokenRegistration
aspire (1)
Backchannel\AuxiliaryBackchannelMonitor.cs (1)
537using var cancellationRegistration = cancellationToken.Register(() => tcs.TrySetCanceled());
Aspire.Dashboard (1)
Model\TraceLinkHelpers.cs (1)
49using var registration = cancellationToken.Register(cts.Cancel);
Aspire.Hosting (5)
ApplicationModel\ResourceLoggerService.cs (1)
438using var _ = _logStreamCts.Token.Register(() => channel.Writer.TryComplete());
Dcp\DcpHost.cs (1)
282using var _ = cancellationToken.Register(s => ((NetworkStream)s!).Close(), stream);
InteractionService.cs (3)
92using var _ = cancellationToken.Register(OnInteractionCancellation, state: newState); 165using var _ = cancellationToken.Register(OnInteractionCancellation, state: newState); 233using var _ = cancellationToken.Register(OnInteractionCancellation, state: newState);
Aspire.Hosting.DevTunnels (1)
DevTunnelCli.cs (1)
261using var ctr = cancellationToken.Register(() =>
aspire-server (1)
JsonRpcServer.cs (1)
219using var registration = cancellationToken.Register(() =>
GenerateDocumentationAndConfigFiles (3)
src\Dependencies\Threading\ProducerConsumer.cs (1)
334using var _ = cancellationToken.Register(
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
552private CancellationTokenRegistration _cancellationTokenRegistration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)
89CancellationTokenRegistration cancellationTokenRegistration = default;
GetDocument.Insider (1)
Commands\GetDocumentCommandWorker.cs (1)
132using (var registration = applicationLifetime.ApplicationStarted.Register(() => waitForStartTcs.TrySetResult(null)))
HelixTestRunner (1)
ProcessUtil.cs (1)
173await using var _ = cancellationToken.Register(() => canceledTcs.TrySetResult(null));
IIS.Tests (1)
ResponseAbortTests.cs (1)
152var originalRegistration = token.Register(() => { });
InMemory.FunctionalTests (1)
Http2\PipeReaderFactory.cs (1)
33using (var registration = cancellationToken.Register(_cancelReader, pipe.Reader))
Metrics (4)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
387protected readonly CancellationTokenRegistration _registration;
src\Dependencies\Threading\ProducerConsumer.cs (1)
334using var _ = cancellationToken.Register(
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
552private CancellationTokenRegistration _cancellationTokenRegistration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)
89CancellationTokenRegistration cancellationTokenRegistration = default;
Metrics.Legacy (4)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
387protected readonly CancellationTokenRegistration _registration;
src\Dependencies\Threading\ProducerConsumer.cs (1)
334using var _ = cancellationToken.Register(
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
552private CancellationTokenRegistration _cancellationTokenRegistration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)
89CancellationTokenRegistration cancellationTokenRegistration = default;
Microsoft.AspNetCore.Components.WebAssembly.Server (2)
DebugProxyLauncher.cs (2)
76var ctr = default(CancellationTokenRegistration);
Microsoft.AspNetCore.Grpc.JsonTranscoding (1)
Internal\HttpContextStreamWriter.cs (1)
47CancellationTokenRegistration? registration = null;
Microsoft.AspNetCore.Mvc.Testing (2)
DeferredHostBuilder.cs (2)
148using var reg = cancellationToken.UnsafeRegister(_ => _hostStartedTcs.TrySetCanceled(), null); 152using var reg2 = _host.Services.GetRequiredService<IHostApplicationLifetime>().ApplicationStarted.UnsafeRegister(_ => _hostStartedTcs.TrySetResult(), null);
Microsoft.AspNetCore.Server.HttpSys (10)
MessagePump.cs (1)
224using var registration = cancellationToken.Register(static state =>
RequestProcessing\ClientCertLoader.cs (1)
31private readonly CancellationTokenRegistration _cancellationRegistration;
RequestProcessing\RequestContext.cs (1)
189internal CancellationTokenRegistration RegisterForCancellation(CancellationToken cancellationToken)
RequestProcessing\RequestStream.cs (2)
221var cancellationRegistration = default(CancellationTokenRegistration);
RequestProcessing\RequestStreamAsyncResult.cs (2)
20private readonly CancellationTokenRegistration _cancellationRegistration; 22internal RequestStreamAsyncResult(RequestStream requestStream, object? userState, AsyncCallback? callback, byte[] buffer, int offset, int size, uint dataAlreadyRead, CancellationTokenRegistration cancellationRegistration)
RequestProcessing\ResponseStreamAsyncResult.cs (3)
22private readonly CancellationTokenRegistration _cancellationRegistration; 29var cancellationRegistration = default(CancellationTokenRegistration);
Microsoft.AspNetCore.Server.IIS (1)
Core\IISHttpServer.cs (1)
36private CancellationTokenRegistration _cancellationTokenRegistration;
Microsoft.AspNetCore.Server.Kestrel.Core (3)
Internal\HttpConnection.cs (1)
117using var closedRegistration = _context.ConnectionContext.ConnectionClosed.Register(state => ((HttpConnection)state!).OnConnectionClosed(), this);
Internal\WebTransport\WebTransportSession.cs (1)
21private readonly CancellationTokenRegistration _connectionClosedRegistration;
Internal\WebTransport\WebTransportStream.cs (1)
18private readonly CancellationTokenRegistration _connectionClosedRegistration;
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (2)
Http1\Http1ConnectionTests.cs (2)
788var originalRegistration = originalToken.Register(() => { }); 802var originalRegistration = originalToken.Register(() => { });
Microsoft.AspNetCore.SignalR.Client.Core (4)
Internal\InvocationRequest.cs (1)
17private readonly CancellationTokenRegistration _cancellationTokenRegistration;
src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (3)
87var registration = cancellationToken.Register((ctsState) => 101private readonly CancellationTokenRegistration _cancellationTokenRegistration; 105public CancelableEnumerator(IAsyncEnumerator<T> asyncEnumerator, CancellationTokenRegistration registration)
Microsoft.AspNetCore.SignalR.Core (7)
HubConnectionContext.cs (3)
37private readonly CancellationTokenRegistration _closedRegistration; 38private readonly CancellationTokenRegistration? _closedRequestedRegistration; 543using (var registration = cts.Token.UnsafeRegister(_cancelReader, input))
src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (3)
87var registration = cancellationToken.Register((ctsState) => 101private readonly CancellationTokenRegistration _cancellationTokenRegistration; 105public CancelableEnumerator(IAsyncEnumerator<T> asyncEnumerator, CancellationTokenRegistration registration)
src\SignalR\common\Shared\ClientResultsManager.cs (1)
122private CancellationTokenRegistration _tokenRegistration;
Microsoft.AspNetCore.SignalR.StackExchangeRedis (2)
RedisHubLifetimeManager.cs (1)
541CancellationTokenRegistration? tokenRegistration = null;
src\SignalR\common\Shared\ClientResultsManager.cs (1)
122private CancellationTokenRegistration _tokenRegistration;
Microsoft.AspNetCore.TestHost (2)
HttpContextBuilder.cs (1)
86var registration = cancellationToken.Register(ClientInitiatedAbort);
ResponseBodyReaderStream.cs (1)
86using var registration = cancellationToken.Register(Cancel);
Microsoft.AspNetCore.WebSockets.Tests (1)
BufferStream.cs (1)
173var registration = cancellationToken.Register(Abort);
Microsoft.CodeAnalysis (3)
DiagnosticAnalyzer\AnalyzerDriver.cs (2)
71private CancellationTokenRegistration? _lazyQueueRegistration; 652_lazyQueueRegistration = default(CancellationTokenRegistration);
DiagnosticAnalyzer\AsyncQueue.cs (1)
364internal CancellationTokenRegistration CancellationTokenRegistration { get; set; }
Microsoft.CodeAnalysis.Analyzers (4)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
387protected readonly CancellationTokenRegistration _registration;
src\Dependencies\Threading\ProducerConsumer.cs (1)
334using var _ = cancellationToken.Register(
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
552private CancellationTokenRegistration _cancellationTokenRegistration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)
89CancellationTokenRegistration cancellationTokenRegistration = default;
Microsoft.CodeAnalysis.AnalyzerUtilities (4)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
387protected readonly CancellationTokenRegistration _registration;
src\Dependencies\Threading\ProducerConsumer.cs (1)
334using var _ = cancellationToken.Register(
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
552private CancellationTokenRegistration _cancellationTokenRegistration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)
89CancellationTokenRegistration cancellationTokenRegistration = default;
Microsoft.CodeAnalysis.BannedApiAnalyzers (4)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
387protected readonly CancellationTokenRegistration _registration;
src\Dependencies\Threading\ProducerConsumer.cs (1)
334using var _ = cancellationToken.Register(
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
552private CancellationTokenRegistration _cancellationTokenRegistration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)
89CancellationTokenRegistration cancellationTokenRegistration = default;
Microsoft.CodeAnalysis.CodeStyle (4)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
387protected readonly CancellationTokenRegistration _registration;
src\Dependencies\Threading\ProducerConsumer.cs (1)
334using var _ = cancellationToken.Register(
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
552private CancellationTokenRegistration _cancellationTokenRegistration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)
89CancellationTokenRegistration cancellationTokenRegistration = default;
Microsoft.CodeAnalysis.EditorFeatures (1)
Tagging\TaggerMainThreadManager.cs (1)
86var registration = _threadingContext.DisposalToken.Register(
Microsoft.CodeAnalysis.EditorFeatures.Test.Utilities (1)
Threading\TaskJoinExtensions.cs (1)
49using (var registration = cancellationToken.Register(() => frame.Continue = false))
Microsoft.CodeAnalysis.InteractiveHost (3)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
387protected readonly CancellationTokenRegistration _registration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
552private CancellationTokenRegistration _cancellationTokenRegistration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)
89CancellationTokenRegistration cancellationTokenRegistration = default;
Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (4)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
387protected readonly CancellationTokenRegistration _registration;
src\Dependencies\Threading\ProducerConsumer.cs (1)
334using var _ = cancellationToken.Register(
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
552private CancellationTokenRegistration _cancellationTokenRegistration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)
89CancellationTokenRegistration cancellationTokenRegistration = default;
Microsoft.CodeAnalysis.PublicApiAnalyzers (4)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
387protected readonly CancellationTokenRegistration _registration;
src\Dependencies\Threading\ProducerConsumer.cs (1)
334using var _ = cancellationToken.Register(
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
552private CancellationTokenRegistration _cancellationTokenRegistration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)
89CancellationTokenRegistration cancellationTokenRegistration = default;
Microsoft.CodeAnalysis.ResxSourceGenerator (4)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
387protected readonly CancellationTokenRegistration _registration;
src\Dependencies\Threading\ProducerConsumer.cs (1)
334using var _ = cancellationToken.Register(
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
552private CancellationTokenRegistration _cancellationTokenRegistration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)
89CancellationTokenRegistration cancellationTokenRegistration = default;
Microsoft.CodeAnalysis.Threading.Package (1)
ProducerConsumer.cs (1)
334using var _ = cancellationToken.Register(
Microsoft.CodeAnalysis.Workspaces (3)
src\Dependencies\Threading\ProducerConsumer.cs (1)
334using var _ = cancellationToken.Register(
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
552private CancellationTokenRegistration _cancellationTokenRegistration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)
89CancellationTokenRegistration cancellationTokenRegistration = default;
Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (1)
Build\ProjectBuildManager.cs (1)
392CancellationTokenRegistration registration = default;
Microsoft.Extensions.Caching.Hybrid (1)
Internal\DefaultHybridCache.StampedeStateT.cs (1)
91using CancellationTokenRegistration reg = token.Register(static obj =>
Microsoft.Extensions.Caching.Hybrid.Tests (4)
StampedeTests.cs (4)
101using var reg = ct.Register(() => Interlocked.Increment(ref cancelCount)); 137using var reg = ct.Register(() => Interlocked.Increment(ref cancelCount)); 190using var reg = ct.Register(() => Interlocked.Increment(ref cancelCount)); 268using var reg = ct.Register(() => Interlocked.Increment(ref cancelCount));
Microsoft.Extensions.Hosting (2)
Internal\ConsoleLifetime.cs (2)
23private CancellationTokenRegistration _applicationStartedRegistration; 24private CancellationTokenRegistration _applicationStoppingRegistration;
Microsoft.Extensions.Hosting.Systemd (2)
SystemdLifetime.cs (2)
22private CancellationTokenRegistration _applicationStartedRegistration; 23private CancellationTokenRegistration _applicationStoppingRegistration;
Microsoft.Extensions.Validation.GeneratorTests (1)
ValidationsGeneratorTestBase.cs (1)
202using var registration = applicationLifetime.ApplicationStarted.Register(() => waitForStartTcs.TrySetResult(0));
Microsoft.JSInterop (2)
JSRuntime.cs (2)
24private readonly ConcurrentDictionary<long, CancellationTokenRegistration> _cancellationRegistrations = new(); 179if (_cancellationRegistrations.TryRemove(taskId, out var registration))
Microsoft.ML.AutoML (4)
API\BinaryClassificationExperiment.cs (1)
452using (var ctRegistration = ct.Register(() =>
API\MulticlassClassificationExperiment.cs (1)
430using (var ctRegistration = ct.Register(() =>
API\RegressionExperiment.cs (1)
384using (var ctRegistration = ct.Register(() =>
AutoMLExperiment\Runner\SweepablePipelineRunner.cs (1)
98using (var ctRegistration = ct.Register(() =>
Microsoft.VisualStudio.LanguageServices.LiveShare (1)
Client\RemoteLanguageServiceWorkspaceHost.cs (1)
91using var token = cancellationToken.Register(() =>
mscorlib (1)
src\libraries\shims\mscorlib\ref\mscorlib.cs (1)
1122[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.CancellationTokenRegistration))]
netstandard (1)
netstandard.cs (1)
2071[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.CancellationTokenRegistration))]
Roslyn.Diagnostics.Analyzers (4)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
387protected readonly CancellationTokenRegistration _registration;
src\Dependencies\Threading\ProducerConsumer.cs (1)
334using var _ = cancellationToken.Register(
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
552private CancellationTokenRegistration _cancellationTokenRegistration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)
89CancellationTokenRegistration cancellationTokenRegistration = default;
RunTests (1)
ProcessRunner.cs (1)
140var registration = cancellationToken.Register(() =>
SignalRSamples (1)
ObservableExtensions.cs (1)
32var abortRegistration = connectionAborted.Register(() => channel.Writer.TryComplete());
System.Data.Common (3)
System\Data\Common\DbCommand.cs (3)
129CancellationTokenRegistration registration = default; 170CancellationTokenRegistration registration = default; 202CancellationTokenRegistration registration = default;
System.IO.Pipelines (10)
System\IO\Pipelines\Pipe.cs (2)
934CancellationTokenRegistration cancellationTokenRegistration = default; 1012CancellationTokenRegistration cancellationTokenRegistration = default;
System\IO\Pipelines\PipeAwaitable.cs (4)
19private CancellationTokenRegistration _cancellationTokenRegistration; 60if (_cancellationTokenRegistration == default(CancellationTokenRegistration)) 178public CancellationTokenRegistration ReleaseCancellationTokenRegistration(out CancellationToken cancellationToken) 181CancellationTokenRegistration cancellationTokenRegistration = _cancellationTokenRegistration;
System\IO\Pipelines\StreamPipeReader.cs (3)
243CancellationTokenRegistration reg = default; 319CancellationTokenRegistration reg = default; 390CancellationTokenRegistration reg = default;
System\IO\Pipelines\StreamPipeWriter.cs (1)
296CancellationTokenRegistration reg = default;
System.IO.Ports (1)
System\IO\Ports\SerialStream.Unix.cs (1)
1081private readonly CancellationTokenRegistration _cancellationTokenRegistration;
System.Net.Http (23)
System\Net\Http\HttpContent.cs (1)
407CancellationTokenRegistration cancellationRegistration = cancellationToken.Register(static s => ((HttpContent)s!).Dispose(), this);
System\Net\Http\SocketsHttpHandler\ChunkedEncodingReadStream.cs (5)
168CancellationTokenRegistration ctr = _connection.RegisterCancellation(cancellationToken); 256CancellationTokenRegistration ctr = _connection!.RegisterCancellation(cancellationToken); 294private int ReadChunksFromConnectionBuffer(Span<byte> buffer, CancellationTokenRegistration cancellationRegistration) 313private ReadOnlyMemory<byte>? ReadChunkFromConnectionBuffer(int maxBytesToRead, CancellationTokenRegistration cancellationRegistration) 473CancellationTokenRegistration ctr = default;
System\Net\Http\SocketsHttpHandler\ConnectionCloseReadStream.cs (2)
57CancellationTokenRegistration ctr = connection.RegisterCancellation(cancellationToken); 118CancellationTokenRegistration ctr = connection.RegisterCancellation(cancellationToken);
System\Net\Http\SocketsHttpHandler\ContentLengthReadStream.cs (3)
82CancellationTokenRegistration ctr = _connection.RegisterCancellation(cancellationToken); 147CancellationTokenRegistration ctr = _connection.RegisterCancellation(cancellationToken); 213CancellationTokenRegistration ctr = default;
System\Net\Http\SocketsHttpHandler\CreditWaiter.cs (1)
22private CancellationTokenRegistration _registration;
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)
1145private readonly CancellationTokenRegistration _cancellationRegistration;
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (4)
77private CancellationTokenRegistration _waitSourceCancellation; 198CancellationTokenRegistration linkedRegistration = default; 1271CancellationTokenRegistration linkedRegistration = cancellationToken.CanBeCanceled && cancellationToken != _requestBodyCancellationSource.Token ? 1411private CancellationTokenRegistration RegisterRequestBodyCancellation(CancellationToken cancellationToken) =>
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (1)
162CancellationTokenRegistration linkedTokenRegistration = cancellationToken.UnsafeRegister(cts => ((CancellationTokenSource)cts!).Cancel(), _requestBodyCancellationSource);
System\Net\Http\SocketsHttpHandler\HttpConnection.cs (2)
551CancellationTokenRegistration cancellationRegistration = RegisterCancellation(cancellationToken); 954private CancellationTokenRegistration RegisterCancellation(CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\RawConnectionStream.cs (3)
64CancellationTokenRegistration ctr = connection.RegisterCancellation(cancellationToken); 120CancellationTokenRegistration ctr = connection.RegisterCancellation(cancellationToken); 211CancellationTokenRegistration ctr = connection.RegisterCancellation(cancellationToken);
System.Net.Ping (1)
System\Net\NetworkInformation\Ping.cs (1)
717using CancellationTokenRegistration _ = cancellationToken.UnsafeRegister(static state => ((Ping)state!).SetCanceled(), this);
System.Net.Quic (5)
src\libraries\Common\src\System\Net\StreamBuffer.cs (1)
294private CancellationTokenRegistration _waitSourceCancellation;
System\Net\Quic\Internal\ResettableValueTaskSource.cs (2)
31private CancellationTokenRegistration _cancellationRegistration; 138CancellationTokenRegistration cancellationRegistration = default;
System\Net\Quic\Internal\ValueTaskSource.cs (2)
27private CancellationTokenRegistration _cancellationRegistration; 98CancellationTokenRegistration cancellationRegistration = default;
System.Net.Sockets (1)
System\Net\Sockets\SocketAsyncContext.Unix.cs (1)
132public CancellationTokenRegistration CancellationRegistration;
System.Net.WebSockets (2)
System\Net\WebSockets\AsyncMutex.cs (1)
251public CancellationTokenRegistration CancellationRegistration { get; set; }
System\Net\WebSockets\ManagedWebSocket.cs (1)
779CancellationTokenRegistration registration = default;
System.Private.CoreLib (46)
src\libraries\System.Private.CoreLib\src\System\Threading\CancellationToken.cs (16)
130/// <returns>The <see cref="CancellationTokenRegistration"/> instance that can 133public CancellationTokenRegistration Register(Action callback) => Register(callback, useSynchronizationContext: false); 154/// <returns>The <see cref="CancellationTokenRegistration"/> instance that can 157public CancellationTokenRegistration Register(Action callback, bool useSynchronizationContext) 184/// <returns>The <see cref="CancellationTokenRegistration"/> instance that can 187public CancellationTokenRegistration Register(Action<object?> callback, object? state) => 198/// <returns>The <see cref="CancellationTokenRegistration"/> instance that can be used to unregister the callback.</returns> 200public CancellationTokenRegistration Register(Action<object?, CancellationToken> callback, object? state) => 223/// <returns>The <see cref="CancellationTokenRegistration"/> instance that can 228public CancellationTokenRegistration Register(Action<object?> callback, object? state, bool useSynchronizationContext) => 247/// <returns>The <see cref="CancellationTokenRegistration"/> instance that can 250public CancellationTokenRegistration UnsafeRegister(Action<object?> callback, object? state) => 260/// <returns>The <see cref="CancellationTokenRegistration"/> instance that can be used to unregister the callback.</returns> 262public CancellationTokenRegistration UnsafeRegister(Action<object?, CancellationToken> callback, object? state) => 282/// <returns>The <see cref="CancellationTokenRegistration"/> instance that can 287private CancellationTokenRegistration Register(Delegate callback, object? state, bool useSynchronizationContext, bool useExecutionContext)
src\libraries\System.Private.CoreLib\src\System\Threading\CancellationTokenRegistration.cs (15)
15public readonly struct CancellationTokenRegistration : IEquatable<CancellationTokenRegistration>, IDisposable, IAsyncDisposable 114/// cref="CancellationTokenRegistration">CancellationTokenRegistration</see> 120public static bool operator ==(CancellationTokenRegistration left, CancellationTokenRegistration right) => left.Equals(right); 123/// Determines whether two <see cref="CancellationTokenRegistration">CancellationTokenRegistration</see> instances are not equal. 128public static bool operator !=(CancellationTokenRegistration left, CancellationTokenRegistration right) => !left.Equals(right); 131/// Determines whether the current <see cref="CancellationTokenRegistration">CancellationTokenRegistration</see> instance is equal to the 136/// Two <see cref="CancellationTokenRegistration">CancellationTokenRegistration</see> instances are equal if 140public override bool Equals([NotNullWhen(true)] object? obj) => obj is CancellationTokenRegistration other && Equals(other); 146/// <param name="other">The other <see cref="CancellationTokenRegistration">CancellationTokenRegistration</see> to which to compare this instance.</param> 148/// Two <see cref="CancellationTokenRegistration">CancellationTokenRegistration</see> instances are equal if 152public bool Equals(CancellationTokenRegistration other) => _node == other._node && _id == other._id; 155/// Serves as a hash function for a <see cref="CancellationTokenRegistration">CancellationTokenRegistration.</see>. 157/// <returns>A hash code for the current <see cref="CancellationTokenRegistration">CancellationTokenRegistration</see> instance.</returns>
src\libraries\System.Private.CoreLib\src\System\Threading\CancellationTokenSource.cs (7)
586internal CancellationTokenRegistration Register( 891private readonly CancellationTokenRegistration _reg1; 912private readonly CancellationTokenRegistration _reg1; 913private readonly CancellationTokenRegistration _reg2; 941private CancellationTokenRegistration[]? _linkingRegistrations; 945_linkingRegistrations = new CancellationTokenRegistration[tokens.Length]; 966CancellationTokenRegistration[]? linkingRegistrations = _linkingRegistrations;
src\libraries\System.Private.CoreLib\src\System\Threading\PeriodicTimer.cs (1)
179private CancellationTokenRegistration _ctr;
src\libraries\System.Private.CoreLib\src\System\Threading\SemaphoreSlim.cs (1)
338CancellationTokenRegistration cancellationTokenRegistration = cancellationToken.UnsafeRegister(s_cancellationTokenCanceledEventHandler, this);
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (5)
305internal StrongBox<CancellationTokenRegistration>? m_cancellationRegistration; // Task's registration with the cancellation token 706CancellationTokenRegistration ctr; 731props.m_cancellationRegistration = new StrongBox<CancellationTokenRegistration>(ctr); 2936private readonly CancellationTokenRegistration _registration; 5919private readonly CancellationTokenRegistration _registration;
src\System\Runtime\ControlledExecution.CoreCLR.cs (1)
65CancellationTokenRegistration ctr = cancellationToken.UnsafeRegister(e => ((Canceler)e!).Cancel(), canceler);
System.Runtime (1)
artifacts\obj\System.Runtime\Debug\net11.0\System.Runtime.Forwards.cs (1)
815[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.CancellationTokenRegistration))]
System.Threading.Channels (2)
System\Threading\Channels\AsyncOperation.cs (1)
36private readonly CancellationTokenRegistration _cancellationRegistration;
System\Threading\Channels\AsyncOperation.netcoreapp.cs (1)
13private static void Unregister(CancellationTokenRegistration registration) =>
System.Threading.RateLimiting (4)
System\Threading\RateLimiting\ConcurrencyLimiter.cs (1)
413private CancellationTokenRegistration _cancellationTokenRegistration;
System\Threading\RateLimiting\FixedWindowRateLimiter.cs (1)
451private CancellationTokenRegistration _cancellationTokenRegistration;
System\Threading\RateLimiting\SlidingWindowRateLimiter.cs (1)
464private CancellationTokenRegistration _cancellationTokenRegistration;
System\Threading\RateLimiting\TokenBucketRateLimiter.cs (1)
465private CancellationTokenRegistration _cancellationTokenRegistration;
System.Threading.Tasks (1)
System.Threading.Tasks.cs (1)
21[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.CancellationTokenRegistration))]
System.Threading.Tasks.Dataflow (6)
Base\DataflowBlock.cs (4)
355private readonly CancellationTokenRegistration _cancellationRegistration; 503Debug.Assert(_cancellationRegistration != default(CancellationTokenRegistration), 1131internal CancellationTokenRegistration _regFromExternalCancellationToken; 1424CancellationTokenRegistration registration = default;
Internal\Common.cs (2)
192CancellationTokenRegistration reg = cancellationToken.Register( 204completionTask.ContinueWith(static (completed, state) => ((CancellationTokenRegistration)state!).Dispose(),
System.Threading.Tasks.Parallel (5)
System\Threading\Tasks\Parallel.cs (4)
953CancellationTokenRegistration ctr = (!parallelOptions.CancellationToken.CanBeCanceled) 954? default(CancellationTokenRegistration) 2552CancellationTokenRegistration ctr = (!parallelOptions.CancellationToken.CanBeCanceled) 2553? default(CancellationTokenRegistration)
System\Threading\Tasks\Parallel.ForEachAsync.cs (1)
511protected readonly CancellationTokenRegistration _registration;
System.Windows.Forms (2)
System\Windows\Forms\Control_InvokeAsync.cs (2)
292CancellationTokenRegistration registration = cancellationToken.Register( 397CancellationTokenRegistration registration = cancellationToken.Register(
Test.Utilities (3)
src\Dependencies\Threading\ProducerConsumer.cs (1)
334using var _ = cancellationToken.Register(
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
552private CancellationTokenRegistration _cancellationTokenRegistration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)
89CancellationTokenRegistration cancellationTokenRegistration = default;
Text.Analyzers (4)
src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
387protected readonly CancellationTokenRegistration _registration;
src\Dependencies\Threading\ProducerConsumer.cs (1)
334using var _ = cancellationToken.Register(
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
552private CancellationTokenRegistration _cancellationTokenRegistration;
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)
89CancellationTokenRegistration cancellationTokenRegistration = default;
Wasm.Performance.Driver (1)
Program.cs (1)
95using var registration = runCancellationToken.Token.Register(async () =>