- Sort Score
- Result 10 results
- Languages All
Results 201 - 210 of 426 for timers (0.03 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
* permits in a cool state, where X = rate * timeToCoolDown, and we have specified a * timeToWarmUp() period, it will cost as the prescribed amount of time. E.g., calling * [acquire(5), acquire(1)] takes exactly the same time as [acquire(2), acquire(3), acquire(1)]. */ public void testTimeToWarmUpIsHonouredEvenWithWeights() { Random random = new Random(); int warmupPermits = 10;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 21.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
* permits in a cool state, where X = rate * timeToCoolDown, and we have specified a * timeToWarmUp() period, it will cost as the prescribed amount of time. E.g., calling * [acquire(5), acquire(1)] takes exactly the same time as [acquire(2), acquire(3), acquire(1)]. */ public void testTimeToWarmUpIsHonouredEvenWithWeights() { Random random = new Random(); int warmupPermits = 10;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 21.9K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java
return null; } }); assertEquals(incrementByNanos * numberOfThreads, ticker.read()); } /** Runs {@code callable} concurrently {@code numberOfThreads} times. */ @GwtIncompatible // concurrency private void runConcurrentTest(int numberOfThreads, Callable<@Nullable Void> callable) throws Exception { ExecutorService executorService = newFixedThreadPool(numberOfThreads);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 6.5K bytes - Viewed (0) -
docs/fr/docs/deployment/https.md
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Tue Aug 06 04:48:30 UTC 2024 - 4.1K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/FakeTickerTest.java
return null; } }); assertEquals(incrementByNanos * numberOfThreads, ticker.read()); } /** Runs {@code callable} concurrently {@code numberOfThreads} times. */ @GwtIncompatible // concurrency private void runConcurrentTest(int numberOfThreads, Callable<@Nullable Void> callable) throws Exception { ExecutorService executorService = newFixedThreadPool(numberOfThreads);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 6.3K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbResourceLocatorImplTest.java
import static org.mockito.ArgumentMatchers.eq; import static org.mockito.Mockito.atLeastOnce; import static org.mockito.Mockito.inOrder; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.times; import static org.mockito.Mockito.verify; import static org.mockito.Mockito.when; import java.net.URL; import java.net.URLConnection; import java.net.URLStreamHandler; import java.net.UnknownHostException;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 17.6K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/session/Smb2SessionSetupRequestTest.java
import static org.junit.jupiter.api.Assertions.assertNotNull; import static org.junit.jupiter.api.Assertions.assertTrue; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.times; import static org.mockito.Mockito.verify; import static org.mockito.Mockito.when; import java.lang.reflect.Field; import java.lang.reflect.Method; import org.junit.jupiter.api.BeforeEach;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 21.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
* operation in order to trigger shutdown, consider instead registering a listener and * implementing {@code stopping}. Note, however, that {@code stopping} does not run at exactly the * same times as {@code triggerShutdown}. */ protected void triggerShutdown() {} /** * Returns the {@link Executor} that will be used to run this service. Subclasses may override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 7.5K bytes - Viewed (0) -
src/test/java/jcifs/smb1/util/LogStreamTest.java
String output = testOutput.toString(); assertTrue(output.contains("test message")); } @Test void testSetInstanceMultipleTimes() { // Test setting instance multiple times PrintStream stream1 = new PrintStream(new ByteArrayOutputStream()); PrintStream stream2 = new PrintStream(new ByteArrayOutputStream()); LogStream.setInstance(stream1);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 8.3K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/ds/DataStoreTest.java
} @Override public void stop() { stopCallCount.incrementAndGet(); } }; // Execute stop multiple times dataStore.stop(); dataStore.stop(); dataStore.stop(); assertEquals(3, stopCallCount.get()); } public void test_store_and_stop_lifecycle() {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 13K bytes - Viewed (0)