Searched refs:ExecutorCoroutineDispatcher (Results 1 – 12 of 12) sorted by relevance
40 assertNull(context[ExecutorCoroutineDispatcher]) in testExecutorCoroutineDispatcher()42 assertNull(updated[ExecutorCoroutineDispatcher]) in testExecutorCoroutineDispatcher()47 …assertSame(Dispatchers.Default as ExecutorCoroutineDispatcher, updated2[ExecutorCoroutineDispatche… in testExecutorCoroutineDispatcher()50 assertEquals(name, updated2.minusKey(ExecutorCoroutineDispatcher)) in testExecutorCoroutineDispatcher()
13 class ExecutorRule(private val numberOfThreads: Int) : TestRule, ExecutorCoroutineDispatcher() {15 private var _executor: ExecutorCoroutineDispatcher? = null
40 fun ExecutorCoroutineDispatcher.dumpThreads(header: String) = in dumpThreads() method
29 runCatching { (_value as? ExecutorCoroutineDispatcher)?.close() } in <lambda>()
19 public abstract class ExecutorCoroutineDispatcher: CoroutineDispatcher(), Closeable { class22 …mpanion object Key : AbstractCoroutineContextKey<CoroutineDispatcher, ExecutorCoroutineDispatcher>(24 { it as? ExecutorCoroutineDispatcher }) in <lambda>()49 public fun ExecutorService.asCoroutineDispatcher(): ExecutorCoroutineDispatcher = in close()71 (this as? ExecutorCoroutineDispatcher)?.executor ?: DispatcherExecutor(this) in close()84 internal abstract class ExecutorCoroutineDispatcherBase : ExecutorCoroutineDispatcher(), Delay {
35 public fun newSingleThreadContext(name: String): ExecutorCoroutineDispatcher = in <lambda>()62 public fun newFixedThreadPoolContext(nThreads: Int, name: String): ExecutorCoroutineDispatcher { in <lambda>()
23 internal object CommonPool : ExecutorCoroutineDispatcher() {
32 private lateinit var dispatcher: ExecutorCoroutineDispatcher59 … Mode.CPU_LIMITED -> closeableDispatcher.limited(N_THREADS) as ExecutorCoroutineDispatcher in <lambda>()60 Mode.BLOCKING -> closeableDispatcher.blocking(N_THREADS) as ExecutorCoroutineDispatcher in <lambda>()
45 ) : ExecutorCoroutineDispatcher() { in toString()148 ) : ExecutorCoroutineDispatcher(), TaskContext, Executor {
14 private lateinit var pool: ExecutorCoroutineDispatcher in <lambda>()
300 public abstract class kotlinx/coroutines/ExecutorCoroutineDispatcher : kotlinx/coroutines/Coroutine…301 public static final field Key Lkotlinx/coroutines/ExecutorCoroutineDispatcher$Key;307 public final class kotlinx/coroutines/ExecutorCoroutineDispatcher$Key : kotlin/coroutines/AbstractC…313 …l fun from (Ljava/util/concurrent/ExecutorService;)Lkotlinx/coroutines/ExecutorCoroutineDispatcher;527 …fun newFixedThreadPoolContext (ILjava/lang/String;)Lkotlinx/coroutines/ExecutorCoroutineDispatcher;528 …nal fun newSingleThreadContext (Ljava/lang/String;)Lkotlinx/coroutines/ExecutorCoroutineDispatcher;1165 …tines/scheduling/ExperimentalCoroutineDispatcher : kotlinx/coroutines/ExecutorCoroutineDispatcher {
153 * `CoroutineDispatcher` and `ExecutorCoroutineDispatcher` experimental coroutine context keys are i…592 * Introduced `ExecutorCoroutineDispatcher` instead of `CloseableCoroutineDispatcher` (see #385).