Searched refs:DefaultExecutor (Results 1 – 16 of 16) sorted by relevance
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | DefaultExecutorStressTest.kt | 14 withContext(DefaultExecutor) { in <lambda>()
47 … while (DefaultExecutor.isThreadPresent) { delay(10) } // hangs if the thread refuses to stop in <lambda>()
48 assertFalse(DefaultExecutor.isThreadPresent) // just to make sure in <lambda>()
59 assertTrue(DefaultExecutor.isThreadPresent) // the worker spawned in <lambda>()
|
| D | VirtualTimeSource.kt | 14 …DefaultExecutor.shutdownForTests(SHUTDOWN_TIMEOUT) // shutdown execution with old time source (in … in withVirtualTimeSource()
17 DefaultExecutor.ensureStarted() // should start with new time source in withVirtualTimeSource()
21 DefaultExecutor.shutdownForTests(SHUTDOWN_TIMEOUT) in withVirtualTimeSource()
|
| D | EventLoopsTest.kt | 60 assertTrue(Thread.currentThread().name.startsWith(DefaultExecutor.THREAD_NAME)) in <lambda>()
63 DefaultExecutor.enqueue(Runnable { in <lambda>()
|
| D | TestBase.kt | 211 DefaultExecutor.shutdownForTests(SHUTDOWN_TIMEOUT) in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | DefaultExecutor.kt | 17 if (!defaultMainDelayOptIn) return DefaultExecutor in initializeDefaultDelay()
24 return if (main.isMissing() || main !is Delay) DefaultExecutor else main in initializeDefaultDelay()
28 internal actual object DefaultExecutor : EventLoopImplBase(), Runnable { object
|
| D | Executors.kt | 155 DefaultExecutor.scheduleResumeAfterDelay(timeMillis, continuation) in scheduleResumeAfterDelay()
162 else -> DefaultExecutor.invokeOnTimeout(timeMillis, block, context) in invokeOnTimeout()
|
| D | Dispatchers.kt | 93 DefaultExecutor.shutdown() in shutdown()
|
| D | EventLoop.kt | 21 DefaultExecutor.schedule(now, delayedTask) in reschedule()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | Deprecated.kt | 54 DefaultExecutor.dispatch(context, block)
63 DefaultExecutor.dispatchYield(context, block)
104 DefaultExecutor.enqueue(coroutineScheduler.createTask(block, context)) in dispatchWithContext()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | CoroutineContext.kt | 10 internal actual object DefaultExecutor : CoroutineDispatcher(), Delay { object
33 internal actual val DefaultDelay: Delay = DefaultExecutor in createDefaultDispatcher()
|
| D | EventLoop.kt | 20 DefaultExecutor.invokeOnTimeout(now, delayedTask, EmptyCoroutineContext) in reschedule()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/knit/ |
| D | TestUtil.kt | 30 DefaultExecutor.shutdownForTests(SHUTDOWN_TIMEOUT) in <lambda>()
43 …DefaultExecutor.shutdownForTests(SHUTDOWN_TIMEOUT) // the last man standing -- cleanup all pending… in <lambda>()
61 shutdownNow().forEach { DefaultExecutor.enqueue(it) } in shutdownDispatcherPools()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | EventLoop.kt | 22 internal actual object DefaultExecutor { in unpark() object
|
| /external/tensorflow/tensorflow/core/distributed_runtime/preemption/ |
| D | preemption_notifier.cc | 64 SIGTERM, thread::Executor::DefaultExecutor(), in SigtermNotifier()
|
| D | preemption_notifier_test.cc | 48 SIGTERM, thread::Executor::DefaultExecutor(), []() {}, in PreemptNotifierTest()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | EventLoop.common.kt | 293 DefaultExecutor.enqueue(task) in dispatch()
529 internal expect object DefaultExecutor { in toString() object
|