CompleteAdding()

void System.Collections.Concurrent.BlockingCollection< T >.CompleteAdding ( )

inline

Definition at line 622 of file BlockingCollection.cs.

    {
        CheckDisposed();
        if (IsAddingCompleted)
        {
            return;
        }
        SpinWait spinWait = default(SpinWait);
        while (true)
        {
            int currentAdders = _currentAdders;
            if (((uint)currentAdders & 0x80000000u) != 0)
            {
                spinWait.Reset();
                while (_currentAdders != int.MinValue)
                {
                    spinWait.SpinOnce();
                }
                return;
            }
            if (Interlocked.CompareExchange(ref _currentAdders, currentAdders | int.MinValue, currentAdders) == currentAdders)
            {
                break;
            }
            spinWait.SpinOnce(-1);
        }
        spinWait.Reset();
        while (_currentAdders != int.MinValue)
        {
            spinWait.SpinOnce();
        }
        if (Count == 0)
        {
            CancelWaitingConsumers();
        }
        CancelWaitingProducers();
    }

References System.Collections.Concurrent.BlockingCollection< T >._currentAdders, System.Collections.Concurrent.BlockingCollection< T >.CancelWaitingConsumers(), System.Collections.Concurrent.BlockingCollection< T >.CancelWaitingProducers(), System.Collections.Concurrent.BlockingCollection< T >.CheckDisposed(), System.Threading.Interlocked.CompareExchange(), System.Collections.Concurrent.BlockingCollection< T >.Count, and System.Collections.Concurrent.BlockingCollection< T >.IsAddingCompleted.