GetUnownedWorkStealingQueue()

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

inlineprivate

Definition at line 474 of file ConcurrentBag.cs.

    {
        int currentManagedThreadId = Environment.CurrentManagedThreadId;
        for (WorkStealingQueue workStealingQueue = _workStealingQueues; workStealingQueue != null; workStealingQueue = workStealingQueue._nextQueue)
        {
            if (workStealingQueue._ownerThreadId == currentManagedThreadId)
            {
                return workStealingQueue;
            }
        }
        return null;
    }

References System.Collections.Concurrent.ConcurrentBag< T >._workStealingQueues, and System.Environment.CurrentManagedThreadId.

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