Home
last modified time | relevance | path

Searched refs:currentWorker (Results 1 – 1 of 1) sorted by relevance

/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/
DCoroutineScheduler.kt336 val currentWorker = currentWorker() in <lambda>() constant
342 if (worker !== currentWorker) { in <lambda>()
357 val task = currentWorker?.findTask(true) in <lambda>()
364 currentWorker?.tryReleaseCpu(WorkerState.TERMINATED) in <lambda>()
387 val currentWorker = currentWorker() in <lambda>() constant
388 val notAdded = currentWorker.submitToLocalQueue(task, tailDispatch) in <lambda>()
395 val skipUnpark = tailDispatch && currentWorker != null in <lambda>()
509 …private fun currentWorker(): Worker? = (Thread.currentThread() as? Worker)?.takeIf { it.scheduler … in <lambda>() method