EnqueueSlow()

void System.Collections.Concurrent.ConcurrentQueue< T >.EnqueueSlow ( T item )

inlineprivateinherited

Definition at line 322 of file ConcurrentQueue.cs.

    {
        while (true)
        {
            ConcurrentQueueSegment<T> tail = _tail;
            if (tail.TryEnqueue(item))
            {
                break;
            }
            lock (_crossSegmentLock)
            {
                if (tail == _tail)
                {
                    tail.EnsureFrozenForEnqueues();
                    int boundedLength = (tail._preservedForObservation ? 32 : Math.Min(tail.Capacity * 2, 1048576));
                    _tail = (tail._nextSegment = new ConcurrentQueueSegment<T>(boundedLength));
                }
            }
        }
    }

References System.Collections.Concurrent.ConcurrentQueue< T >._crossSegmentLock, System.Collections.Concurrent.ConcurrentQueue< T >._tail, System.item, and System.Math.Min().

Referenced by System.Collections.Concurrent.ConcurrentQueue< T >.Enqueue().