Searched refs:blockingTasks (Results 1 – 3 of 3) sorted by relevance
28 val blockingTasks = CopyOnWriteArrayList<Deferred<*>>() in <lambda>() constant33 blockingTasks += blockingAwait(blockingDispatcher, blockingBarrier) in <lambda>()34 blockingTasks += blockingAwait(blockingDispatcher, blockingBarrier) in <lambda>()38 blockingTasks += blockingAwait(blockingDispatcher, blockingBarrier) in <lambda>()45 blockingTasks.forEach { require(it.isActive) } in <lambda>()47 blockingTasks.awaitAll() in <lambda>()
89 val blockingTasks = (1..10).flatMap { in <lambda>() constant100 blockingTasks.forEach { require(it.isActive) } in <lambda>()103 blockingTasks.joinAll() in <lambda>()113 … val blockingTasks = (1..tasksNum).map { launch(blockingDispatcher.value) { barrier.await() } } in <lambda>() constant123 blockingTasks.joinAll() in <lambda>()
275 …private inline fun blockingTasks(state: Long): Int = (state and BLOCKING_MASK shr BLOCKING_SHIFT).… in <lambda>() method in kotlinx.coroutines.scheduling.CoroutineScheduler433 val blocking = blockingTasks(state) in <lambda>()469 val blocking = blockingTasks(state) in <lambda>()