Count

int System.Collections.Concurrent.ConcurrentQueue< T >.Count

get

Implements System.Collections.ICollection.

Definition at line 39 of file ConcurrentQueue.cs.

    {
        get
        {
            SpinWait spinWait = default(SpinWait);
            ConcurrentQueueSegment<T> head;
            ConcurrentQueueSegment<T> tail;
            int num;
            int num2;
            int num3;
            int num4;
            while (true)
            {
                head = _head;
                tail = _tail;
                num = Volatile.Read(ref head._headAndTail.Head);
                num2 = Volatile.Read(ref head._headAndTail.Tail);
                if (head == tail)
                {
                    if (head == _head && tail == _tail && num == Volatile.Read(ref head._headAndTail.Head) && num2 == Volatile.Read(ref head._headAndTail.Tail))
                    {
                        return GetCount(head, num, num2);
                    }
                }
                else if (head._nextSegment == tail)
                {
                    num3 = Volatile.Read(ref tail._headAndTail.Head);
                    num4 = Volatile.Read(ref tail._headAndTail.Tail);
                    if (head == _head && tail == _tail && num == Volatile.Read(ref head._headAndTail.Head) && num2 == Volatile.Read(ref head._headAndTail.Tail) && num3 == Volatile.Read(ref tail._headAndTail.Head) && num4 == Volatile.Read(ref tail._headAndTail.Tail))
                    {
                        break;
                    }
                }
                else
                {
                    lock (_crossSegmentLock)
                    {
                        if (head == _head && tail == _tail)
                        {
                            int num5 = Volatile.Read(ref tail._headAndTail.Head);
                            int num6 = Volatile.Read(ref tail._headAndTail.Tail);
                            if (num == Volatile.Read(ref head._headAndTail.Head) && num2 == Volatile.Read(ref head._headAndTail.Tail) && num5 == Volatile.Read(ref tail._headAndTail.Head) && num6 == Volatile.Read(ref tail._headAndTail.Tail))
                            {
                                int num7 = GetCount(head, num, num2) + GetCount(tail, num5, num6);
                                for (ConcurrentQueueSegment<T> nextSegment = head._nextSegment; nextSegment != tail; nextSegment = nextSegment._nextSegment)
                                {
                                    num7 += nextSegment._headAndTail.Tail - nextSegment.FreezeOffset;
                                }
                                return num7;
                            }
                        }
                    }
                }
                spinWait.SpinOnce();
            }
            return GetCount(head, num, num2) + GetCount(tail, num3, num4);
        }
    }

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