Searched refs:DefaultExecutor (Results 1 – 13 of 13) sorted by relevance
14 internal actual object DefaultExecutor : CoroutineDispatcher(), Delay { in takeEventLoop() object28 DefaultExecutor in loopWasShutDown()31 internal actual val DefaultDelay: Delay = DefaultExecutor in loopWasShutDown()35 return if (combined !== DefaultExecutor && combined[ContinuationInterceptor] == null) in loopWasShutDown()36 combined + DefaultExecutor else combined in loopWasShutDown()
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>()
14 …DefaultExecutor.shutdown(SHUTDOWN_TIMEOUT) // shutdown execution with old time source (in case it … in withVirtualTimeSource()17 DefaultExecutor.ensureStarted() // should start with new time source in withVirtualTimeSource()21 DefaultExecutor.shutdown(SHUTDOWN_TIMEOUT) in withVirtualTimeSource()
60 assertTrue(Thread.currentThread().name.startsWith(DefaultExecutor.THREAD_NAME)) in <lambda>()63 DefaultExecutor.enqueue(Runnable { in <lambda>()
180 DefaultExecutor.shutdown(SHUTDOWN_TIMEOUT) in <lambda>()
17 …assert { this !== DefaultExecutor } // otherwise default execution was shutdown with tasks in it (… in reschedule()18 DefaultExecutor.schedule(now, delayedTask) in reschedule()
108 DefaultExecutor.enqueue(block) in dispatch()127 shutdownNow().forEach { DefaultExecutor.enqueue(it) } in shutdown()
10 internal actual val DefaultDelay: Delay = DefaultExecutor13 internal actual object DefaultExecutor : EventLoopImplBase(), Runnable { object
119 DefaultExecutor.scheduleResumeAfterDelay(timeMillis, continuation) in scheduleResumeAfterDelay()130 else -> DefaultExecutor.invokeOnTimeout(timeMillis, block, context) in invokeOnTimeout()
70 DefaultExecutor.dispatch(context, block) in toString()79 DefaultExecutor.dispatchYield(context, block) in toString()120 DefaultExecutor.enqueue(coroutineScheduler.createTask(block, context)) in toString()
33 DefaultExecutor.shutdown(SHUTDOWN_TIMEOUT) in <lambda>()47 … DefaultExecutor.shutdown(SHUTDOWN_TIMEOUT) // the last man standing -- cleanup all pending tasks in <lambda>()66 shutdownNow().forEach { DefaultExecutor.enqueue(it) } in shutdownDispatcherPools()
22 internal actual object DefaultExecutor { in unpark() object
287 DefaultExecutor.enqueue(task) in dispatch()525 internal expect object DefaultExecutor { in toString() object