Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 18 for wakeup (0.04 seconds)

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

         * to return. Fortunately, a wait on a Condition is allowed to return early on account of a
         * "spurious wakeup," so we're allowed to convert interruptions into such wakeups.
         */
    
        /*
         * Since we can't loop inside awaitUninterruptibly(Condition, ...), the user is responsible for
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 23:24:32 GMT 2026
    - 22.5K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

                    removeWaiter(node);
                    throw new InterruptedException();
                  }
    
                  // Otherwise re-read and check doneness. If we loop then it must have been a spurious
                  // wakeup
                  localValue = valueField;
                  if (localValue != null & notInstanceOfDelegatingToFuture(localValue)) {
                    return getDoneValue(localValue);
                  }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 33.2K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

       * occur except for those produced by awaitUninterruptibly itself in response to interrupts.
       *
       * This isn't guaranteed to work, so any further spurious wakeups would probably cause failures in
       * tests that assert that a certain amount of time has passed, that the method returned `false`,
       * or even that an interrupt occurred (if the spurious wakeup happens before the interrupt).
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 38.1K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

       * occur except for those produced by awaitUninterruptibly itself in response to interrupts.
       *
       * This isn't guaranteed to work, so any further spurious wakeups would probably cause failures in
       * tests that assert that a certain amount of time has passed, that the method returned `false`,
       * or even that an interrupt occurred (if the spurious wakeup happens before the interrupt).
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 38.1K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        waiter2.awaitWaiting();
        // The waiter queue should be waiter2->waiter1
    
        // This should wake up waiter1 and cause the waiter1 node to be removed.
        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
        LockSupport.unpark(waiter2); // spurious wakeup
        waiter2.awaitWaiting(); // should eventually re-park
    
        future.set(null);
        waiter2.join();
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        waiter2.awaitWaiting();
        // The waiter queue should be waiter2->waiter1
    
        // This should wake up waiter1 and cause the waiter1 node to be removed.
        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
        LockSupport.unpark(waiter2); // spurious wakeup
        waiter2.awaitWaiting(); // should eventually re-park
    
        future.set(null);
        waiter2.join();
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/Monitor.java

       * called when waits are interrupted.
       *
       * <p>On the other hand, if a signalled thread wakes up to discover that its guard is still not
       * satisfied, it does *not* need to call this method before returning to wait. This can only
       * happen due to spurious wakeup (ignorable) or another thread acquiring the lock before the
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 43.5K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/cache/PopulatedCachesTest.java

      }
    
      private List<Entry<Object, Object>> warmUp(LoadingCache<Object, Object> cache) {
        return warmUp(cache, WARMUP_MIN, WARMUP_MAX);
      }
    
      /**
       * Returns the entries that were added to the map, so they won't fall out of a map with weak or
       * soft references until the caller drops the reference to the returned entries.
       */
      private List<Entry<Object, Object>> warmUp(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 15.4K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        List<Integer> callOrder = new ArrayList<>();
    
        class FakeOp implements Runnable {
          final int op;
    
          FakeOp(int op) {
            this.op = op;
          }
    
          @Override
          public void run() {
            callOrder.add(op);
          }
        }
    
        e.execute(new FakeOp(0));
        e.execute(new FakeOp(1));
        e.execute(new FakeOp(2));
        fakePool.runAll();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 10.5K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        for (int i = 0; i < 8; i++) {
          limiter.acquire(); // // #1
        }
        stopwatch.sleepMillis(4500); // #2: back to cold state (warmup period + repay last acquire)
        for (int i = 0; i < 3; i++) { // only three steps, we're somewhere in the warmup period
          limiter.acquire(); // #3
        }
    
        limiter.setRate(4.0); // double the rate!
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 22K bytes
    - Click Count (0)
Back to Top