Searched refs:localQueue (Results 1 – 1 of 1) sorted by relevance
349 …worker.localQueue.offloadAllWorkTo(globalBlockingQueue) // Doesn't actually matter which queue to … in <lambda>()506 return localQueue.add(task, fair = tailDispatch) in <lambda>()530 val queueSize = worker.localQueue.size in <lambda>()600 val localQueue: WorkQueue = WorkQueue() in <lambda>() constant in kotlinx.coroutines.scheduling.CoroutineScheduler.Worker722 assert { localQueue.size == 0 } in <lambda>()861 localQueue.poll() ?: globalBlockingQueue.removeFirstOrNull() in <lambda>()876 localQueue.poll()?.let { return it } in <lambda>()895 assert { localQueue.size == 0 } in <lambda>()909 assert { localQueue.size == 0 } in <lambda>()911 localQueue.tryStealBlockingFrom(victim = worker.localQueue) in <lambda>()[all …]