Searched refs:ExperimentalCoroutineDispatcher (Results 1 – 14 of 14) sorted by relevance
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | CoroutineSchedulerTest.kt | 109 ExperimentalCoroutineDispatcher(-1, 4) in <lambda>()
114 ExperimentalCoroutineDispatcher(1, -4) in <lambda>()
119 ExperimentalCoroutineDispatcher(4, 1) in <lambda>()
124 val dispatcher = ExperimentalCoroutineDispatcher(1, 1) in <lambda>()
134 ExperimentalCoroutineDispatcher(1, 1).use { in <lambda>()
|
| D | SharingWorkerClassTest.kt | 16 val dispatcher = ExperimentalCoroutineDispatcher(1, schedulerName = "first") in <lambda>()
17 val dispatcher2 = ExperimentalCoroutineDispatcher(1, schedulerName = "second") in <lambda>()
42 ExperimentalCoroutineDispatcher(1).close() in <lambda>()
|
| D | CoroutineSchedulerStressTest.kt | 18 private var dispatcher: ExperimentalCoroutineDispatcher = ExperimentalCoroutineDispatcher()
|
| D | CoroutineSchedulerCloseStressTest.kt | 31 private lateinit var closeableDispatcher: ExperimentalCoroutineDispatcher
56 closeableDispatcher = ExperimentalCoroutineDispatcher(N_THREADS) in <lambda>()
|
| D | SchedulerTestBase.kt | 72 private var _dispatcher: ExperimentalCoroutineDispatcher? = null
76 _dispatcher = ExperimentalCoroutineDispatcher(
|
| D | BlockingCoroutineDispatcherTerminationStressTest.kt | 13 private val baseDispatcher = ExperimentalCoroutineDispatcher(
|
| D | BlockingCoroutineDispatcherWorkSignallingStressTest.kt | 21 val dispatcher = ExperimentalCoroutineDispatcher(CORES_COUNT) in <lambda>()
|
| D | CoroutineDispatcherTest.kt | 137 … val dispatcher = ExperimentalCoroutineDispatcher(1, 1, IDLE_WORKER_KEEP_ALIVE_NS, "SomeTestName") in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | Dispatcher.kt | 16 internal object DefaultScheduler : ExperimentalCoroutineDispatcher() {
40 public open class ExperimentalCoroutineDispatcher( in toString() class
144 private val dispatcher: ExperimentalCoroutineDispatcher,
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/ |
| D | SemaphoreBenchmark.kt | 10 import kotlinx.coroutines.scheduling.ExperimentalCoroutineDispatcher in <lambda>()
87 …EXPERIMENTAL({ parallelism -> ExperimentalCoroutineDispatcher(corePoolSize = parallelism, maxPoolS… in parallelism()
|
| D | ParametrizedDispatcherBase.kt | 33 ExperimentalCoroutineDispatcher(CORES_COUNT).also { closeable = it } in setup()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/ |
| D | PingPongWithBlockingContext.kt | 31 private val experimental = ExperimentalCoroutineDispatcher(8)
|
| /external/kotlinx.coroutines/ |
| D | CHANGES.md | 454 * Add optional prefix to thread names of `ExperimentalCoroutineDispatcher` (#661).
455 * Fixed bug when `ExperimentalCoroutineDispatcher` could end up in inconsistent state if `Thread` c…
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/api/ |
| D | kotlinx-coroutines-core.api | 1165 public class kotlinx/coroutines/scheduling/ExperimentalCoroutineDispatcher : kotlinx/coroutines/Exe…
1173 …nthetic fun blocking$default (Lkotlinx/coroutines/scheduling/ExperimentalCoroutineDispatcher;IILja…
|