- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for awaitNanos (0.04 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Lockable.kt
internal inline fun Lockable.notify() = (this as Object).notify() internal inline fun Lockable.notifyAll() = (this as Object).notifyAll() internal inline fun Lockable.awaitNanos(nanos: Long) { val ms = nanos / 1_000_000L val ns = nanos - (ms * 1_000_000L) if (ms > 0L || nanos > 0) { (this as Object).wait(ms, ns.toInt()) } } internal inline fun Lockable.assertLockNotHeld() {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 2.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
override fun coordinatorWait( taskRunner: TaskRunner, nanos: Long, ) { taskRunner.assertLockHeld() if (nanos > 0) { taskRunner.awaitNanos(nanos) } } override fun <T> decorate(queue: BlockingQueue<T>) = queue override fun execute( taskRunner: TaskRunner, runnable: Runnable, ) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 10.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Monitor.java
return false; } } boolean satisfied = false; boolean threw = true; try { satisfied = guard.isSatisfied() || awaitNanos( guard, (startTime == 0L) ? timeoutNanos : remainingNanos(startTime, timeoutNanos), reentrant); threw = false; return satisfied; } finally {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 42.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
condition.awaitUninterruptibly(); } finally { lock.unlock(); } } @Override public long awaitNanos(long nanosTimeout) throws InterruptedException { lock.lock(); try { return condition.awaitNanos(nanosTimeout); } finally { lock.unlock(); } } @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 31.7K bytes - Viewed (0)