Searched refs:ExecutorCoroutineDispatcher (Results 1 – 12 of 12) sorted by relevance
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Executors.kt | 20 public abstract class ExecutorCoroutineDispatcher: CoroutineDispatcher(), Closeable { class
23 …mpanion object Key : AbstractCoroutineContextKey<CoroutineDispatcher, ExecutorCoroutineDispatcher>(
25 { it as? ExecutorCoroutineDispatcher }) in <lambda>()
41 public actual typealias CloseableCoroutineDispatcher = ExecutorCoroutineDispatcher in close()
69 public fun ExecutorService.asCoroutineDispatcher(): ExecutorCoroutineDispatcher = in close()
108 (this as? ExecutorCoroutineDispatcher)?.executor ?: DispatcherExecutor(this) in close()
115 …utorCoroutineDispatcherImpl(override val executor: Executor) : ExecutorCoroutineDispatcher(), Dela…
|
| D | ThreadPoolDispatcher.kt | 34 public actual fun newSingleThreadContext(name: String): ExecutorCoroutineDispatcher = in <lambda>()
62 …ic actual fun newFixedThreadPoolContext(nThreads: Int, name: String): ExecutorCoroutineDispatcher { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | DispatcherKeyTest.kt | 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()
|
| D | ExecutorRule.kt | 13 class ExecutorRule(private val numberOfThreads: Int) : TestRule, ExecutorCoroutineDispatcher() {
15 private var _executor: ExecutorCoroutineDispatcher? = null
|
| D | Threads.kt | 40 fun ExecutorCoroutineDispatcher.dumpThreads(header: String) = in dumpThreads() method
|
| D | FailingCoroutinesMachineryTest.kt | 29 runCatching { (_value as? ExecutorCoroutineDispatcher)?.close() } in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/knit/ |
| D | ClosedAfterGuideTestExecutor.kt | 11 internal fun newSingleThreadContext(name: String): ExecutorCoroutineDispatcher = ClosedAfterGuideTe… in newSingleThreadContext()
13 internal fun newFixedThreadPoolContext(nThreads: Int, name: String): ExecutorCoroutineDispatcher = in newSingleThreadContext()
17 @JvmField val dispatcher: ExecutorCoroutineDispatcher, // for debugging & tests in newSingleThreadContext()
28 ) : ExecutorCoroutineDispatcher() {
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | Dispatcher.kt | 44 internal object DefaultIoScheduler : ExecutorCoroutineDispatcher(), Executor {
86 ) : ExecutorCoroutineDispatcher() { in toString()
|
| D | Deprecated.kt | 29 ) : ExecutorCoroutineDispatcher() {
116 ) : ExecutorCoroutineDispatcher(), TaskContext, Executor { in createScheduler()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| D | StateFlowStressTest.kt | 14 private lateinit var pool: ExecutorCoroutineDispatcher in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/api/ |
| D | kotlinx-coroutines-core.api | 319 public abstract class kotlinx/coroutines/ExecutorCoroutineDispatcher : kotlinx/coroutines/Coroutine…
320 public static final field Key Lkotlinx/coroutines/ExecutorCoroutineDispatcher$Key;
326 public final class kotlinx/coroutines/ExecutorCoroutineDispatcher$Key : kotlin/coroutines/AbstractC…
332 …l fun from (Ljava/util/concurrent/ExecutorService;)Lkotlinx/coroutines/ExecutorCoroutineDispatcher;
555 …fun newFixedThreadPoolContext (ILjava/lang/String;)Lkotlinx/coroutines/ExecutorCoroutineDispatcher;
556 …nal fun newSingleThreadContext (Ljava/lang/String;)Lkotlinx/coroutines/ExecutorCoroutineDispatcher;
1177 …tines/scheduling/ExperimentalCoroutineDispatcher : kotlinx/coroutines/ExecutorCoroutineDispatcher {
|
| /external/kotlinx.coroutines/ |
| D | CHANGES.md | 460 * `CoroutineDispatcher` and `ExecutorCoroutineDispatcher` experimental coroutine context keys are i…
899 * Introduced `ExecutorCoroutineDispatcher` instead of `CloseableCoroutineDispatcher` (see #385).
|