- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 52 for awaitTermination (0.36 sec)
-
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
// WAIT #2 barrier.await(1, TimeUnit.SECONDS); assertFalse(executor.awaitTermination(20, TimeUnit.MILLISECONDS)); // WAIT #3 barrier.await(1, TimeUnit.SECONDS); assertTrue(executor.awaitTermination(1, TimeUnit.SECONDS)); assertTrue(executor.awaitTermination(0, TimeUnit.SECONDS)); assertTrue(executor.isShutdown());
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (3) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
// WAIT #2 barrier.await(1, TimeUnit.SECONDS); assertFalse(executor.awaitTermination(20, TimeUnit.MILLISECONDS)); // WAIT #3 barrier.await(1, TimeUnit.SECONDS); assertTrue(executor.awaitTermination(1, TimeUnit.SECONDS)); assertTrue(executor.awaitTermination(0, TimeUnit.SECONDS)); assertTrue(executor.isShutdown());
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/DataIndexHelper.java
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 12K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
MockExecutor mock = new MockExecutor(); TestExecutor testExecutor = new TestExecutor(mock); assertFalse(testExecutor.awaitTermination(10, TimeUnit.MILLISECONDS)); mock.assertLastMethodCalled("awaitTermination"); assertFalse(testExecutor.isTerminated()); mock.assertLastMethodCalled("isTerminated"); assertFalse(testExecutor.isShutdown());
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Jan 05 19:41:03 GMT 2023 - 9.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListeningExecutorServiceTest.java
assertThat(Duration.ofNanos(recordedTimeout)).isEqualTo(Duration.ofDays(365)); } public void testAwaitTermination() throws Exception { boolean result = executorService.awaitTermination(Duration.ofMinutes(144)); assertThat(result).isTrue(); assertThat(recordedTimeUnit).isEqualTo(NANOSECONDS); assertThat(Duration.ofNanos(recordedTimeout)).isEqualTo(Duration.ofMinutes(144)); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Fri Jun 02 12:45:23 GMT 2023 - 4.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
MockExecutor mock = new MockExecutor(); TestExecutor testExecutor = new TestExecutor(mock); assertFalse(testExecutor.awaitTermination(10, TimeUnit.MILLISECONDS)); mock.assertLastMethodCalled("awaitTermination"); assertFalse(testExecutor.isTerminated()); mock.assertLastMethodCalled("isTerminated"); assertFalse(testExecutor.isShutdown());
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Jan 05 19:41:03 GMT 2023 - 9.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
protected ForwardingExecutorService() {} @Override protected abstract ExecutorService delegate(); @CheckReturnValue @Override public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { return delegate().awaitTermination(timeout, unit); } @Override public <T extends @Nullable Object> List<Future<T>> invokeAll(
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 4.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
} } finally { if (interrupted) { Thread.currentThread().interrupt(); } } } /** * Invokes {@code executor.}{@link ExecutorService#awaitTermination(long, TimeUnit) * awaitTermination(long, TimeUnit)} uninterruptibly with no timeout. * * @since 30.0 */ @J2ktIncompatible @GwtIncompatible // concurrency
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) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java
aa.set(i, (double) COUNTDOWN); } Counter c1 = new Counter(aa); Counter c2 = new Counter(aa); Thread t1 = newStartedThread(c1); Thread t2 = newStartedThread(c2); awaitTermination(t1); awaitTermination(t2); assertEquals(SIZE * COUNTDOWN, c1.counts + c2.counts); } /** a deserialized serialized array holds same values */ public void testSerialization() throws Exception {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 10K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
assertTrue(future.isDone()); assertTrue(successLatch.await(200, MILLISECONDS)); assertTrue(listenerLatch.await(200, MILLISECONDS)); latch.countDown(); exec.shutdown(); exec.awaitTermination(100, MILLISECONDS); } /** * Tests that all listeners complete, even if they were added before or after the future was
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0)