ExecuteCallbackHandlers()

void System.Threading.CancellationTokenSource.ExecuteCallbackHandlers ( bool throwOnFirstException )

inlineprivateinherited

Definition at line 570 of file CancellationTokenSource.cs.

    {
        Registrations registrations = Interlocked.Exchange(ref _registrations, null);
        if (registrations == null)
        {
            Interlocked.Exchange(ref _state, 2);
            return;
        }
        registrations.ThreadIDExecutingCallbacks = Environment.CurrentManagedThreadId;
        List<Exception> list = null;
        try
        {
            while (true)
            {
                registrations.EnterLock();
                CallbackNode callbacks;
                try
                {
                    callbacks = registrations.Callbacks;
                    if (callbacks == null)
                    {
                        break;
                    }
                    if (callbacks.Next != null)
                    {
                        callbacks.Next.Prev = null;
                    }
                    registrations.Callbacks = callbacks.Next;
                    registrations.ExecutingCallbackId = callbacks.Id;
                    callbacks.Id = 0L;
                    goto IL_0080;
                }
                finally
                {
                    registrations.ExitLock();
                }
                IL_0080:
                try
                {
                    if (callbacks.SynchronizationContext != null)
                    {
                        callbacks.SynchronizationContext.Send(delegate(object s)
                        {
                            CallbackNode callbackNode = (CallbackNode)s;
                            callbackNode.Registrations.ThreadIDExecutingCallbacks = Environment.CurrentManagedThreadId;
                            callbackNode.ExecuteCallback();
                        }, callbacks);
                        registrations.ThreadIDExecutingCallbacks = Environment.CurrentManagedThreadId;
                    }
                    else
                    {
                        callbacks.ExecuteCallback();
                    }
                }
                catch (Exception item) when (!throwOnFirstException)
                {
                    (list ?? (list = new List<Exception>())).Add(item);
                }
            }
        }
        finally
        {
            _state = 2;
            Interlocked.Exchange(ref registrations.ExecutingCallbackId, 0L);
        }
        if (list == null)
        {
            return;
        }
        throw new AggregateException(list);
    }

References System.Threading.CancellationTokenSource._registrations, System.Threading.CancellationTokenSource._state, System.Collections.Generic.Dictionary< TKey, TValue >.Add(), System.Environment.CurrentManagedThreadId, System.Threading.Interlocked.Exchange(), System.item, System.L, System.list, and System.s.

Referenced by System.Threading.CancellationTokenSource.NotifyCancellation().