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); 243private static bool TryStealFromTo(WorkStealingQueue? startInclusive, WorkStealingQueue? endExclusive, [MaybeNullWhen(false)] out T result, bool take) 245for (WorkStealingQueue? queue = startInclusive; queue != endExclusive; queue = queue._nextQueue) 324for (WorkStealingQueue? queue = _workStealingQueues; queue != null; queue = queue._nextQueue) 418WorkStealingQueue? local = GetCurrentThreadWorkStealingQueue(forceCreate: false); 438for (WorkStealingQueue? queue = _workStealingQueues; queue != null; queue = queue._nextQueue) 516for (WorkStealingQueue? queue = _workStealingQueues; queue != null; queue = queue._nextQueue) 535WorkStealingQueue? local = GetCurrentThreadWorkStealingQueue(forceCreate: false); 563for (WorkStealingQueue? queue = _workStealingQueues; queue != null; queue = queue._nextQueue) 619WorkStealingQueue? head = _workStealingQueues; // stable at least until GlobalQueuesLock is released in UnfreezeBag 622for (WorkStealingQueue? queue = head; queue != null; queue = queue._nextQueue) 629for (WorkStealingQueue? queue = head; queue != null; queue = queue._nextQueue) 648for (WorkStealingQueue? queue = _workStealingQueues; queue != null; queue = queue._nextQueue) 691internal readonly WorkStealingQueue? _nextQueue; 697internal WorkStealingQueue(WorkStealingQueue? nextQueue)