TryEnqueue()

bool System.Collections.Concurrent.ConcurrentQueueSegment< T >.TryEnqueue ( T item )

inline

Definition at line 133 of file ConcurrentQueueSegment.cs.

    {
        Slot[] slots = _slots;
        while (true)
        {
            int num = Volatile.Read(ref _headAndTail.Tail);
            int num2 = num & _slotsMask;
            int num3 = Volatile.Read(ref slots[num2].SequenceNumber);
            int num4 = num3 - num;
            if (num4 == 0)
            {
                if (Interlocked.CompareExchange(ref _headAndTail.Tail, num + 1, num) == num)
                {
                    slots[num2].Item = item;
                    Volatile.Write(ref slots[num2].SequenceNumber, num + 1);
                    return true;
                }
            }
            else if (num4 < 0)
            {
                break;
            }
        }
        return false;
    }

References System.Collections.Concurrent.ConcurrentQueueSegment< T >._headAndTail, System.Collections.Concurrent.ConcurrentQueueSegment< T >._slots, System.Collections.Concurrent.ConcurrentQueueSegment< T >._slotsMask, System.Threading.Interlocked.CompareExchange(), System.Collections.Concurrent.ConcurrentQueueSegment< T >.Slot.Item, System.item, System.Threading.Volatile.Read(), System.Collections.Concurrent.PaddedHeadAndTail.Tail, and System.Threading.Volatile.Write().