CreateWorkStealingQueueForCurrentThread()

WorkStealingQueue System.Collections.Concurrent.ConcurrentBag< T >.CreateWorkStealingQueueForCurrentThread ( )

inlineprivate

Definition at line 459 of file ConcurrentBag.cs.

    {
        lock (GlobalQueuesLock)
        {
            WorkStealingQueue workStealingQueues = _workStealingQueues;
            WorkStealingQueue workStealingQueue = ((workStealingQueues != null) ? GetUnownedWorkStealingQueue() : null);
            if (workStealingQueue == null)
            {
                workStealingQueue = (_workStealingQueues = new WorkStealingQueue(workStealingQueues));
            }
            _locals.Value = workStealingQueue;
            return workStealingQueue;
        }
    }

References System.Collections.Concurrent.ConcurrentBag< T >._workStealingQueues, System.Collections.Concurrent.ConcurrentBag< T >.GetUnownedWorkStealingQueue(), and System.Collections.Concurrent.ConcurrentBag< T >.GlobalQueuesLock.

Referenced by System.Collections.Concurrent.ConcurrentBag< T >.GetCurrentThreadWorkStealingQueue().