Searched refs:globalBlockingQueue (Results 1 – 1 of 1) sorted by relevance
116 val globalBlockingQueue = GlobalQueue() in <lambda>() constant120 globalBlockingQueue.addLast(task) in <lambda>()349 …worker.localQueue.offloadAllWorkTo(globalBlockingQueue) // Doesn't actually matter which queue to … in <lambda>()353 globalBlockingQueue.close() in <lambda>()359 ?: globalBlockingQueue.removeFirstOrNull() in <lambda>()861 localQueue.poll() ?: globalBlockingQueue.removeFirstOrNull() in <lambda>()863 globalBlockingQueue.removeFirstOrNull() in <lambda>()887 return globalBlockingQueue.removeFirstOrNull() in <lambda>()889 globalBlockingQueue.removeFirstOrNull()?.let { return it } in <lambda>()