| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | TimeSource.kt | 22 fun unpark(thread: Thread) in currentTimeMillis() method
67 internal inline fun unpark(thread: Thread) { in unpark() method
68 timeSource?.unpark(thread) ?: LockSupport.unpark(thread) in unpark()
|
| D | EventLoop.kt | 10 protected actual fun unpark() { in unpark() method in kotlinx.coroutines.EventLoopImplPlatform
13 unpark(thread) in unpark()
|
| D | Builders.kt | 67 LockSupport.unpark(blockedThread) in afterCompletionInternal()
|
| D | DefaultExecutor.kt | 129 _thread?.let { unpark(it) } // wake up thread if present in shutdown()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | VirtualTimeSource.kt | 113 override fun unpark(thread: Thread) { in toString() method in kotlinx.coroutines.VirtualTimeSource
116 LockSupport.unpark(thread) in toString()
155 threads.keys.forEach { LockSupport.unpark(it) } in toString()
|
| D | EventLoopsTest.kt | 138 waitingThread.value?.let { LockSupport.unpark(it) } in fireEvent()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | EventLoop.kt | 10 protected actual fun unpark() { /* does nothing */ } in unpark() method in kotlinx.coroutines.EventLoopImplPlatform
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | EventLoop.common.kt | 172 protected fun unpark() in delayNanosToMillis() method
279 unpark() in dispatch()
355 SCHEDULE_OK -> if (shouldUnpark(delayedTask)) unpark() in schedule()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | EventLoop.kt | 18 protected actual fun unpark(): Unit = unsupported() in unpark() method in kotlinx.coroutines.EventLoopImplPlatform
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | InterruptibleTask.java | 175 LockSupport.unpark((Thread) currentRunner); in interruptTask()
|
| D | AbstractFuture.java | 200 void unpark() { in unpark() method in AbstractFuture.Waiter
207 LockSupport.unpark(w); in unpark()
1030 currentWaiter.unpark(); in releaseWaiters()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | InterruptibleTask.java | 175 LockSupport.unpark((Thread) currentRunner); in interruptTask()
|
| D | AbstractFuture.java | 200 void unpark() { in unpark() method in AbstractFuture.Waiter
207 LockSupport.unpark(w); in unpark()
1030 currentWaiter.unpark(); in releaseWaiters()
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | InterruptibleTaskTest.java | 102 LockSupport.unpark(Thread.currentThread()); // simulate a spurious wakeup. in testInterruptIsSlow()
|
| D | AbstractFutureTest.java | 179 LockSupport.unpark(waiter2); // spurious wakeup in testRemoveWaiter_interruption()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | InterruptibleTaskTest.java | 102 LockSupport.unpark(Thread.currentThread()); // simulate a spurious wakeup. in testInterruptIsSlow()
|
| D | AbstractFutureTest.java | 179 LockSupport.unpark(waiter2); // spurious wakeup in testRemoveWaiter_interruption()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | CoroutineScheduler.kt | 310 LockSupport.unpark(worker) in <lambda>()
436 LockSupport.unpark(worker) in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/ |
| D | build.gradle | 80 …systemProperty 'kotlinx.coroutines.scheduler.keep.alive.sec', '100000' // any unpark problem hangs…
|