- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 269 for seconds (0.19 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
} } } /* Half of a 1-second timeout in nanoseconds */ private static final long HALF_SECOND_NANOS = NANOSECONDS.convert(1L, SECONDS) / 2; public void testShutdownAndAwaitTermination_immediateShutdown() throws Exception { ExecutorService service = Executors.newSingleThreadExecutor(); assertTrue(shutdownAndAwaitTermination(service, 1L, SECONDS)); assertTrue(service.isTerminated()); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java
* the License. */ package com.google.common.util.concurrent.testing; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static java.util.concurrent.TimeUnit.SECONDS; import com.google.common.annotations.GwtIncompatible; import com.google.common.util.concurrent.ListenableFuture; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException;
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri May 12 18:12:42 GMT 2023 - 3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
assertThrows(IllegalArgumentException.class, () -> builder.refreshAfterWrite(0, SECONDS)); } @GwtIncompatible // refreshAfterWrite public void testRefresh_setTwice() { CacheBuilder<Object, Object> builder = CacheBuilder.newBuilder().refreshAfterWrite(3600, SECONDS); assertThrows(IllegalStateException.class, () -> builder.refreshAfterWrite(3600, SECONDS)); } public void testTicker_setTwice() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Oct 03 20:10:02 GMT 2023 - 23.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestPlatform.java
import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.SECONDS; import static junit.framework.Assert.assertFalse; import static junit.framework.Assert.fail; import com.google.common.annotations.GwtCompatible; import java.util.concurrent.ExecutionException;
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/NullCacheTest.java
import static com.google.common.cache.TestingRemovalListeners.queuingRemovalListener; import static com.google.common.truth.Truth.assertThat; import static java.util.concurrent.TimeUnit.SECONDS; import static org.junit.Assert.assertThrows; import com.google.common.cache.CacheLoader.InvalidCacheLoadException; import com.google.common.cache.TestingRemovalListeners.QueuingRemovalListener;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
Future<?> possiblyIgnoredError1 = testExecutor.schedule(Executors.callable(DO_NOTHING), 5, TimeUnit.SECONDS); mock.assertLastMethodCalled("scheduleCallable", 5, TimeUnit.SECONDS); } public void testSchedule_repeating() { MockExecutor mock = new MockExecutor(); TestExecutor testExecutor = new TestExecutor(mock);
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Wed Dec 16 19:54:45 GMT 2020 - 7.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
blockingCallable.waitForStart(); // Give the second task a chance to (incorrectly) start up while the first task is running. assertThat(future2.isDone()).isFalse(); // Stop the first task. The second task should then run. blockingCallable.stop(); executor.shutdown(); assertThat(executor.awaitTermination(10, TimeUnit.SECONDS)).isTrue(); assertThat(getDone(future2)).isFalse(); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
blockingCallable.waitForStart(); // Give the second task a chance to (incorrectly) start up while the first task is running. assertThat(future2.isDone()).isFalse(); // Stop the first task. The second task should then run. blockingCallable.stop(); executor.shutdown(); assertThat(executor.awaitTermination(10, TimeUnit.SECONDS)).isTrue(); assertThat(getDone(future2)).isFalse(); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
assertEquals(3L, countDownLatch.getCount()); list.execute(); // Verify that all of the runnables execute in a reasonable amount of time. assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); } public void testExecute_idempotent() { final AtomicInteger runCalled = new AtomicInteger(); list.add( new Runnable() { @Override public void run() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 4.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/PopulatedCachesTest.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 15K bytes - Viewed (0)