LocalPush()

void System.Threading.ThreadPoolWorkQueue.WorkStealingQueue.LocalPush ( object obj )

inline

Definition at line 100 of file ThreadPoolWorkQueue.cs.

        {
            int num = m_tailIndex;
            if (num == int.MaxValue)
            {
                num = LocalPush_HandleTailOverflow();
            }
            if (num < m_headIndex + m_mask)
            {
                Volatile.Write(ref m_array[num & m_mask], obj);
                m_tailIndex = num + 1;
                return;
            }
            bool lockTaken = false;
            try
            {
                m_foreignLock.Enter(ref lockTaken);
                int headIndex = m_headIndex;
                int num2 = m_tailIndex - m_headIndex;
                if (num2 >= m_mask)
                {
                    object[] array = new object[m_array.Length << 1];
                    for (int i = 0; i < m_array.Length; i++)
                    {
                        array[i] = m_array[(i + headIndex) & m_mask];
                    }
                    m_array = array;
                    m_headIndex = 0;
                    num = (m_tailIndex = num2);
                    m_mask = (m_mask << 1) | 1;
                }
                Volatile.Write(ref m_array[num & m_mask], obj);
                m_tailIndex = num + 1;
            }
            finally
            {
                if (lockTaken)
                {
                    m_foreignLock.Exit(useMemoryBarrier: false);
                }
            }
        }

References System.array, System.Threading.SpinLock.Enter(), System.Threading.SpinLock.Exit(), System.Threading.ThreadPoolWorkQueue.WorkStealingQueue.LocalPush_HandleTailOverflow(), System.Threading.ThreadPoolWorkQueue.WorkStealingQueue.m_array, System.Threading.ThreadPoolWorkQueue.WorkStealingQueue.m_foreignLock, System.Threading.ThreadPoolWorkQueue.WorkStealingQueue.m_headIndex, System.Threading.ThreadPoolWorkQueue.WorkStealingQueue.m_mask, System.Threading.ThreadPoolWorkQueue.WorkStealingQueue.m_tailIndex, System.obj, and System.Threading.Volatile.Write().