- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for releaseWaiters (0.06 seconds)
-
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFutureState.java
return true; } return false; } final @Nullable Object value() { return value; } final @Nullable Listener listeners() { return listeners; } final void releaseWaiters() {} AbstractFutureState() {} static final Object NULL = new Object(); static final LazyLogger log = new LazyLogger(AbstractFuture.class); static final boolean GENERATE_CANCELLATION_CAUSES = false;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Feb 21 02:38:37 GMT 2025 - 1.9K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java
final @Nullable Listener listeners() { return listenersField; } /** Releases all threads in the {@link #waitersField} list, and clears the list. */ final void releaseWaiters() { Waiter head = gasWaiters(Waiter.TOMBSTONE); for (Waiter currentWaiter = head; currentWaiter != null; currentWaiter = currentWaiter.next) { currentWaiter.unpark(); } }
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) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
@RetainedLocalRef AbstractFuture<?> future = param; @RetainedLocalRef Listener next = null; outer: while (true) { future.releaseWaiters(); /* * We call interruptTask() immediately before afterDone() so that migrating between the two * can be a no-op. */ if (callInterruptTask) { future.interruptTask();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 14:39:00 GMT 2026 - 43.6K bytes - Click Count (0)