- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 23 for wakeup (0.04 seconds)
-
android/guava/src/com/google/common/util/concurrent/OverflowAvoidingLockSupport.java
static void parkNanos(@Nullable Object blocker, long nanos) { // Even in the extremely unlikely event that a thread unblocks itself early after only 68 years, // this is indistinguishable from a spurious wakeup, which LockSupport allows. LockSupport.parkNanos(blocker, min(nanos, MAX_NANOSECONDS_THRESHOLD)); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Feb 10 11:51:21 GMT 2026 - 1.6K bytes - Click Count (0) -
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 forCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 23:24:32 GMT 2026 - 22.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
isInterruptibleRegistered.countDown(); try { new CountDownLatch(1).await(); // the interrupt will wake us up } catch (InterruptedException ie) { // continue } LockSupport.unpark(Thread.currentThread()); // simulate a spurious wakeup. return null; } @Override boolean isDone() { return false;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
isInterruptibleRegistered.countDown(); try { new CountDownLatch(1).await(); // the interrupt will wake us up } catch (InterruptedException ie) { // continue } LockSupport.unpark(Thread.currentThread()); // simulate a spurious wakeup. return null; } @Override boolean isDone() { return false;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.2K bytes - Click Count (0) -
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) -
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) -
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) -
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) -
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) -
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)