Searched refs:awaitTermination (Results 1 - 25 of 33) sorted by relevance

12

/external/guava/guava/src/com/google/common/util/concurrent/
H A DForwardingExecutorService.java48 public boolean awaitTermination(long timeout, TimeUnit unit) method in class:ForwardingExecutorService
50 return delegate().awaitTermination(timeout, unit);
H A DWrappingExecutorService.java162 public final boolean awaitTermination(long timeout, TimeUnit unit) method in class:WrappingExecutorService
164 return delegate.awaitTermination(timeout, unit);
H A DMoreExecutors.java205 service.awaitTermination(terminationTimeout, timeUnit);
341 public boolean awaitTermination(long timeout, TimeUnit unit) method in class:MoreExecutors.SameThreadExecutorService
457 public boolean awaitTermination(long timeout, TimeUnit unit) method in class:MoreExecutors.ListeningDecorator
459 return delegate.awaitTermination(timeout, unit);
881 if (!service.awaitTermination(halfTimeoutNanos, TimeUnit.NANOSECONDS)) {
885 service.awaitTermination(halfTimeoutNanos, TimeUnit.NANOSECONDS);
/external/guava/guava-bootstrap/src/java/util/concurrent/
H A DExecutorService.java25 boolean awaitTermination(long timeout, TimeUnit unit) method in interface:ExecutorService
/external/guava/guava-tests/test/com/google/common/util/concurrent/
H A DAbstractListeningExecutorServiceTest.java108 public boolean awaitTermination(long timeout, TimeUnit unit) { method in class:AbstractListeningExecutorServiceTest.TestListeningExecutorService
H A DMoreExecutorsTest.java223 assertFalse(executor.awaitTermination(20, TimeUnit.MILLISECONDS));
227 assertTrue(executor.awaitTermination(1, TimeUnit.SECONDS));
228 assertTrue(executor.awaitTermination(0, TimeUnit.SECONDS));
520 shutdownFirst.verify(service).awaitTermination(2, TimeUnit.SECONDS);
527 when(service.awaitTermination(2, TimeUnit.SECONDS)).thenThrow(new InterruptedException());
640 when(service.awaitTermination(HALF_SECOND_NANOS, NANOSECONDS)).thenReturn(true);
644 verify(service).awaitTermination(HALF_SECOND_NANOS, NANOSECONDS);
649 when(service.awaitTermination(HALF_SECOND_NANOS, NANOSECONDS))
654 verify(service, times(2)).awaitTermination(HALF_SECOND_NANOS, NANOSECONDS);
660 when(service.awaitTermination(HALF_SECOND_NANO
[all...]
H A DAtomicDoubleArrayTest.java212 awaitTermination(t);
326 awaitTermination(t1);
327 awaitTermination(t2);
H A DJSR166TestCase.java510 exec.awaitTermination(2 * LONG_DELAY_MS, MILLISECONDS));
776 void awaitTermination(Thread t, long timeoutMillis) { method in class:JSR166TestCase
794 void awaitTermination(Thread t) { method in class:JSR166TestCase
795 awaitTermination(t, LONG_DELAY_MS);
H A DWrappingExecutorServiceTest.java53 assertFalse(testExecutor.awaitTermination(10, TimeUnit.MILLISECONDS));
54 mock.assertLastMethodCalled("awaitTermination");
210 public boolean awaitTermination(long timeout, TimeUnit unit) { method in class:WrappingExecutorServiceTest.MockExecutor
211 lastMethodCalled = "awaitTermination";
H A DAtomicDoubleTest.java128 awaitTermination(t);
H A DWrappingScheduledExecutorServiceTest.java164 public boolean awaitTermination(long timeout, TimeUnit unit) { method in class:WrappingScheduledExecutorServiceTest.MockExecutor
H A DAbstractScheduledServiceTest.java180 assertTrue(service.executor().awaitTermination(100, TimeUnit.MILLISECONDS));
216 assertTrue(service.executor().awaitTermination(100, TimeUnit.MILLISECONDS));
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/
H A DAbstractListenableFutureTest.java200 exec.awaitTermination(100, TimeUnit.MILLISECONDS);
244 exec.awaitTermination(500, TimeUnit.MILLISECONDS);
H A DTestingExecutors.java124 @Override public boolean awaitTermination(long timeout, TimeUnit unit) { method in class:TestingExecutors.NoOpScheduledExecutorService
H A DSameThreadScheduledExecutorService.java74 public boolean awaitTermination(long timeout, TimeUnit unit) method in class:SameThreadScheduledExecutorService
77 return delegate.awaitTermination(timeout, unit);
/external/jetty/src/java/org/eclipse/jetty/util/thread/
H A DExecutorThreadPool.java174 _executor.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
/external/robolectric/src/main/java/com/xtremelabs/robolectric/util/
H A DRobolectricBackgroundExecutorService.java37 public boolean awaitTermination(long l, TimeUnit timeUnit) throws InterruptedException { method in class:RobolectricBackgroundExecutorService
/external/jmdns/src/javax/jmdns/impl/
H A DJmmDNSImpl.java106 executor.awaitTermination(DNSConstants.CLOSE_TIMEOUT, TimeUnit.MILLISECONDS);
215 executor.awaitTermination(timeout, TimeUnit.MILLISECONDS);
418 executor.awaitTermination(timeout, TimeUnit.MILLISECONDS);
/external/junit/src/org/junit/internal/runners/
H A DMethodRoadie.java69 boolean terminated= service.awaitTermination(timeout,
/external/owasp/sanitizer/src/tests/org/owasp/html/
H A DHtmlSanitizerFuzzerTest.java142 executor.awaitTermination(runCount * 4, TimeUnit.SECONDS);
/external/vogar/src/vogar/tasks/
H A DTaskQueue.java79 runners.awaitTermination(FOREVER, TimeUnit.SECONDS);
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
H A DDispatcherTest.java168 @Override public boolean awaitTermination(long timeout, TimeUnit unit) method in class:DispatcherTest.RecordingExecutor
H A DSocksProxy.java91 if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
/external/guava/guava-tests/test/com/google/common/collect/
H A DQueuesTest.java68 threadPool.awaitTermination(1, TimeUnit.SECONDS));
/external/guava/guava-tests/test/com/google/common/cache/
H A DCacheBuilderTest.java580 threadPool.awaitTermination(300, TimeUnit.SECONDS);

Completed in 1049 milliseconds

12