- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 140 for waitms (0.03 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java
volatile @Nullable Waiter waitersField; /** Non-volatile write of the thread to the {@link Waiter#thread} field. */ private static void putThread(Waiter waiter, Thread newValue) { ATOMIC_HELPER.putThread(waiter, newValue); } /** Non-volatile write of the waiter to the {@link Waiter#next} field. */ private static void putNext(Waiter waiter, @Nullable Waiter newValue) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 33.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractFutureState.java
volatile @Nullable Waiter waitersField; /** Non-volatile write of the thread to the {@link Waiter#thread} field. */ private static void putThread(Waiter waiter, Thread newValue) { ATOMIC_HELPER.putThread(waiter, newValue); } /** Non-volatile write of the waiter to the {@link Waiter#next} field. */ private static void putNext(Waiter waiter, @Nullable Waiter newValue) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 34.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Monitor.java
guard.condition.signalAll(); } } /** Records that the current thread is about to wait on the specified guard. */ @GuardedBy("lock") private void beginWaitingFor(Guard guard) { int waiters = guard.waiterCount++; if (waiters == 0) { // push guard onto activeGuards guard.next = activeGuards; activeGuards = guard; } }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 42.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt
* * Writes are subject to the write window of the stream and the connection. Until there is a * window sufficient to send [byteCount], the caller will block. For example, a user of * `HttpURLConnection` who flushes more bytes to the output stream than the connection's write * window will block. * * Zero [byteCount] writes are not subject to flow control and will not block. The only use case
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 31.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
waiter2.join(); } public void testRemoveWaiter_polling() throws Exception { AbstractFuture<String> future = new AbstractFuture<String>() {}; WaiterThread waiter = new WaiterThread(future); waiter.start(); waiter.awaitWaiting(); PollingThread poller = new PollingThread(future); poller.start(); PollingThread poller2 = new PollingThread(future); poller2.start();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 46.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
waiter2.join(); } public void testRemoveWaiter_polling() throws Exception { AbstractFuture<String> future = new AbstractFuture<String>() {}; WaiterThread waiter = new WaiterThread(future); waiter.start(); waiter.awaitWaiting(); PollingThread poller = new PollingThread(future); poller.start(); PollingThread poller2 = new PollingThread(future); poller2.start();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 46.8K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java
} /** * Waits for the crawling process to terminate indefinitely. */ public void awaitTermination() { awaitTermination(0); } /** * Waits for the crawling process to terminate for a specified duration. * @param millis The maximum time to wait in milliseconds. A value of 0 means wait indefinitely. */
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 14K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Service.java
void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException; /** * Waits for the {@link Service} to reach the {@linkplain State#TERMINATED terminated state}. * * @throws IllegalStateException if the service {@linkplain State#FAILED fails}. * @since 15.0 */ void awaitTerminated(); /** * Waits for the {@link Service} to reach a terminal state (either {@link Service.State#TERMINATED
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 12.2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
// // TODO(user): Consider scaling by number of mutator threads, // e.g. using Thread#activeCount() return max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L)); } /** * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector * as necessary to try to ensure that this will happen. * * @throws RuntimeException if timed out or interrupted while waiting
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 11.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException; /** * Waits for the {@link Service} to reach the {@linkplain State#TERMINATED terminated state}. * * @throws IllegalStateException if the service {@linkplain State#FAILED fails}. * @since 15.0 */ void awaitTerminated(); /** * Waits for the {@link Service} to reach a terminal state (either {@link Service.State#TERMINATED
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 10.8K bytes - Viewed (0)