Searched refs:GlobalQueue (Results 1 – 5 of 5) sorted by relevance
19 private val stolenTasks = Array(stealersCount) { GlobalQueue() } in <lambda>()20 private val globalQueue = GlobalQueue() // only producer will use it89 val stolen = GlobalQueue() in testSingleProducerSingleStealer()118 private fun GlobalQueue.addAll(tasks: Collection<Task>) { in GlobalQueue() method
37 val offload = GlobalQueue() in <lambda>()49 val globalQueue = GlobalQueue() in <lambda>()84 internal fun GlobalQueue.drain(): List<Long> { in drain()
140 fun offloadAllWorkTo(globalQueue: GlobalQueue) { in offloadAllWorkTo()174 private fun pollTo(queue: GlobalQueue): Boolean { in pollTo()
109 internal class GlobalQueue : LockFreeTaskQueue<Task>(singleConsumer = false) in toString() class
114 val globalCpuQueue = GlobalQueue() in <lambda>()116 val globalBlockingQueue = GlobalQueue() in <lambda>()