- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 74 for Sait (0.25 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
manager.startAsync(); afterStarted.countDown(); // We do not call awaitHealthy because, due to races, that method may throw an exception. But // we really just want to wait for the thread to be in the failure callback so we wait for that // explicitly instead. failEnter.await(); assertFalse("State should be updated before calling listeners", manager.isHealthy()); // now we want to stop the services.
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
"R0.20, R0.10, R0.10, R0.10"); // #7 (cont.), note, this matches #5 } public void testBurstyAndUpdate() { RateLimiter rateLimiter = RateLimiter.create(1.0, stopwatch); rateLimiter.acquire(1); // no wait rateLimiter.acquire(1); // R1.00, to repay previous rateLimiter.setRate(2.0); // update the rate! rateLimiter.acquire(1); // R1.00, to repay previous (the previous was under the old rate!)
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 21.6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
if (i == 10) { new Thread(() -> latch.countDown()).start(); } future.addListener(listenerLatch::countDown, exec); } assertSame(Boolean.TRUE, future.get()); // Wait for the listener latch to complete. listenerLatch.await(500, MILLISECONDS); exec.shutdown(); exec.awaitTermination(500, MILLISECONDS); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
} /** A typical timeout value we'll use in the tests. */ private static final long SMALL_TIMEOUT_MILLIS = 10; /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */ private static final long EXPECTED_HANG_DELAY_MILLIS = 75; /** * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked. */
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Apr 17 14:48:57 GMT 2023 - 27.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
* </ul> * * @throws ExecutionException if the computation threw an exception * @throws CancellationException if the computation was cancelled * @throws TimeoutException if the wait timed out */ @CanIgnoreReturnValue @J2ktIncompatible @GwtIncompatible // TODO @SuppressWarnings("GoodTime") // should accept a java.time.Duration @ParametricNullness
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 14.4K bytes - Viewed (0) -
guava/src/com/google/common/cache/CacheStats.java
* loadExceptionCount} are incremented, and the total loading time, in nanoseconds, is * added to {@code totalLoadTime}. * <li>Cache lookups that encounter a missing cache entry that is still loading will wait * for loading to complete (whether successful or not) and then increment {@code * missCount}. * </ul> * <li>When an entry is evicted from the cache, {@code evictionCount} is incremented.
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Sun Aug 07 02:38:22 GMT 2022 - 12.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java
new AtomicReference<WeakReference<?>>( (WeakReference<?>) sepFwrCons.newInstance(sepStopwatchA.get(), sepFrqA.get())); assertNotNull(sepStopwatchA.get()); // Clear all references to the Stopwatch and wait for it to be gc'd. sepStopwatchA.set(null); GcFinalization.awaitClear(sepStopwatchRef.get()); // Return a weak reference to the parallel ClassLoader. This is the reference that should
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 16 03:24:50 GMT 2021 - 13.3K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/CacheStats.java
* loadExceptionCount} are incremented, and the total loading time, in nanoseconds, is * added to {@code totalLoadTime}. * <li>Cache lookups that encounter a missing cache entry that is still loading will wait * for loading to complete (whether successful or not) and then increment {@code * missCount}. * </ul> * <li>When an entry is evicted from the cache, {@code evictionCount} is incremented.
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Sun Aug 07 02:38:22 GMT 2022 - 12.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
// Once the backing futures are done there's a (brief) moment where we know nothing assertThat(futureResult.toString()).matches("CombinedFuture@\\w+\\[status=PENDING]"); callableBlocking.countDown(); // Need to wait for resultFuture to be returned. assertTrue(executor.awaitTermination(10, SECONDS)); // But once the async function has returned a future we can include that in the toString assertThat(futureResult.toString())
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheBuilderTest.java
computationStarted.countDown(); cache.getUnchecked("b"); computationComplete.countDown(); } }) .start(); // wait for the computingEntry to be created computationStarted.await(); cache.invalidateAll(); // let the computation proceed computingLatch.countDown();
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Oct 03 20:10:02 GMT 2023 - 25.5K bytes - Viewed (0)