Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for awaitNanos (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to top