1 instantiation of WorkStealingQueue
System.Collections.Concurrent (1)
System\Collections\Concurrent\ConcurrentBag.cs (1)
134_workStealingQueues = queue = new WorkStealingQueue(head);
29 references to WorkStealingQueue
System.Collections.Concurrent (29)
System\Collections\Concurrent\ConcurrentBag.cs (29)
36private readonly ThreadLocal<WorkStealingQueue> _locals; 38private volatile WorkStealingQueue? _workStealingQueues; 45_locals = new ThreadLocal<WorkStealingQueue>(); 60_locals = new ThreadLocal<WorkStealingQueue>(); 62WorkStealingQueue queue = GetCurrentThreadWorkStealingQueue(forceCreate: true)!; 101WorkStealingQueue? queue = GetCurrentThreadWorkStealingQueue(forceCreate: false); 114WorkStealingQueue? queue = GetCurrentThreadWorkStealingQueue(forceCreate: false); 121private WorkStealingQueue? GetCurrentThreadWorkStealingQueue(bool forceCreate) => 125private WorkStealingQueue CreateWorkStealingQueueForCurrentThread() 129WorkStealingQueue? head = _workStealingQueues; 131WorkStealingQueue? queue = head != null ? GetUnownedWorkStealingQueue() : null; 147private WorkStealingQueue? GetUnownedWorkStealingQueue() 155for (WorkStealingQueue? queue = _workStealingQueues; queue != null; queue = queue._nextQueue) 213WorkStealingQueue? localQueue = GetCurrentThreadWorkStealingQueue(forceCreate: false); 237private static bool TryStealFromTo(WorkStealingQueue? startInclusive, WorkStealingQueue? endExclusive, [MaybeNullWhen(false)] out T result, bool take) 239for (WorkStealingQueue? queue = startInclusive; queue != endExclusive; queue = queue._nextQueue) 318for (WorkStealingQueue? queue = _workStealingQueues; queue != null; queue = queue._nextQueue) 412WorkStealingQueue? local = GetCurrentThreadWorkStealingQueue(forceCreate: false); 432for (WorkStealingQueue? queue = _workStealingQueues; queue != null; queue = queue._nextQueue) 510for (WorkStealingQueue? queue = _workStealingQueues; queue != null; queue = queue._nextQueue) 529WorkStealingQueue? local = GetCurrentThreadWorkStealingQueue(forceCreate: false); 557for (WorkStealingQueue? queue = _workStealingQueues; queue != null; queue = queue._nextQueue) 613WorkStealingQueue? head = _workStealingQueues; // stable at least until GlobalQueuesLock is released in UnfreezeBag 616for (WorkStealingQueue? queue = head; queue != null; queue = queue._nextQueue) 623for (WorkStealingQueue? queue = head; queue != null; queue = queue._nextQueue) 642for (WorkStealingQueue? queue = _workStealingQueues; queue != null; queue = queue._nextQueue) 685internal readonly WorkStealingQueue? _nextQueue; 691internal WorkStealingQueue(WorkStealingQueue? nextQueue)