Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for remainingNanos (0.08 sec)

  1. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

        try {
          long remainingNanos = unit.toNanos(timeout);
          long end = System.nanoTime() + remainingNanos;
    
          while (true) {
            try {
              // CountDownLatch treats negative timeouts just like zero.
              return latch.await(remainingNanos, NANOSECONDS);
            } catch (InterruptedException e) {
              interrupted = true;
              remainingNanos = end - System.nanoTime();
            }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.8K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/Monitor.java

                } else {
                  long remainingNanos;
                  if (startTime == 0L) {
                    startTime = initNanoTime(timeoutNanos);
                    remainingNanos = timeoutNanos;
                  } else {
                    remainingNanos = remainingNanos(startTime, timeoutNanos);
                  }
                  satisfied = awaitNanos(guard, remainingNanos, signalBeforeWaiting);
                }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 42.8K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

        boolean interrupted = false;
        try {
          long remainingNanos = unit.toNanos(timeout);
          long end = System.nanoTime() + remainingNanos;
    
          while (true) {
            try {
              // TimeUnit.timedJoin() treats negative timeouts just like zero.
              NANOSECONDS.timedJoin(thread, remainingNanos);
              return;
            } catch (InterruptedException e) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

        boolean interrupted = false;
        try {
          long remainingNanos = unit.toNanos(timeout);
          long end = System.nanoTime() + remainingNanos;
    
          while (true) {
            try {
              // TimeUnit.timedJoin() treats negative timeouts just like zero.
              NANOSECONDS.timedJoin(thread, remainingNanos);
              return;
            } catch (InterruptedException e) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

          return getDoneValue(localValue);
        }
        // we delay calling nanoTime until we know we will need to either park or spin
        long endNanos = remainingNanos > 0 ? System.nanoTime() + remainingNanos : 0;
        long_wait_loop:
        if (remainingNanos >= SPIN_THRESHOLD_NANOS) {
          Waiter oldHead = waitersField;
          if (oldHead != Waiter.TOMBSTONE) {
            Waiter node = new Waiter();
            do {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

          return getDoneValue(localValue);
        }
        // we delay calling nanoTime until we know we will need to either park or spin
        long endNanos = remainingNanos > 0 ? System.nanoTime() + remainingNanos : 0;
        long_wait_loop:
        if (remainingNanos >= SPIN_THRESHOLD_NANOS) {
          Waiter oldHead = waitersField;
          if (oldHead != Waiter.TOMBSTONE) {
            Waiter node = new Waiter();
            do {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
Back to top