Searched refs:CoroutineScheduler (Results 1 – 9 of 9) sorted by relevance
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | CoroutineSchedulerTest.kt | 19 CoroutineScheduler(1, 1).use { in <lambda>()
33 CoroutineScheduler(2, 2).use { in <lambda>()
49 CoroutineScheduler(1, 1).use { in <lambda>()
73 CoroutineScheduler(1, 1).use { in <lambda>()
97 CoroutineScheduler(1, 128).use { scheduler -> in <lambda>()
155 private fun testUniformDistribution(worker: CoroutineScheduler.Worker, bound: Int) { in <lambda>()
|
| D | CoroutineDispatcherTest.kt | 25 require(Thread.currentThread() is CoroutineScheduler.Worker) in <lambda>()
135 .count { it is CoroutineScheduler.Worker && it.name.contains("SomeTestName") } in <lambda>()
143 .count { it is CoroutineScheduler.Worker && it.name.contains("SomeTestName") } in <lambda>()
|
| D | CoroutineSchedulerLivenessStressTest.kt | 8 import kotlinx.coroutines.scheduling.CoroutineScheduler.Companion.MAX_SUPPORTED_POOL_SIZE
13 …private val scheduler = lazy { CoroutineScheduler(CORE_POOL_SIZE, MAX_SUPPORTED_POOL_SIZE, Long.MA… in <lambda>()
|
| D | SchedulerTestBase.kt | 46 …eads = Thread.getAllStackTraces().keys.asSequence().filter { it is CoroutineScheduler.Worker }.cou… in checkPoolThreadsExist()
51 … return Thread.getAllStackTraces().keys.asSequence().filter { it is CoroutineScheduler.Worker } in maxSequenceNumber()
|
| D | BlockingCoroutineDispatcherMixedStealingStressTest.kt | 66 && it is CoroutineScheduler.Worker } in testBlockingProgressPreventedExternal()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | Tasks.kt | 36 minValue = CoroutineScheduler.MIN_SUPPORTED_POOL_SIZE
44 CoroutineScheduler.MAX_SUPPORTED_POOL_SIZE
46 maxValue = CoroutineScheduler.MAX_SUPPORTED_POOL_SIZE
|
| D | CoroutineScheduler.kt | 92 internal class CoroutineScheduler( in <lambda>() class
597 inline val scheduler get() = this@CoroutineScheduler in <lambda>()
646 this@CoroutineScheduler.tryAcquireCpuPermit() -> { in <lambda>()
961 internal fun isSchedulerWorker(thread: Thread) = thread is CoroutineScheduler.Worker
969 internal fun mayNotBlock(thread: Thread) = thread is CoroutineScheduler.Worker &&
970 thread.state == CoroutineScheduler.WorkerState.CPU_ACQUIRED
|
| D | Dispatcher.kt | 124 …private fun createScheduler() = CoroutineScheduler(corePoolSize, maxPoolSize, idleWorkerKeepAliveN… in toString()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | RejectedExecutionTest.kt | 162 … if (thread !is CoroutineScheduler.Worker) error("Not a thread from Dispatchers.Default: $thread") in <lambda>()
163 assertEquals(CoroutineScheduler.WorkerState.CPU_ACQUIRED, thread.state) in <lambda>()
168 if (thread !is CoroutineScheduler.Worker) error("Not a thread from Dispatchers.IO: $thread") in <lambda>()
169 assertEquals(CoroutineScheduler.WorkerState.BLOCKING, thread.state) in <lambda>()
|