| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | MoreExecutorsTest.java | 223 assertFalse(executor.awaitTermination(20, TimeUnit.MILLISECONDS)); in testDirectExecutorServiceServiceTermination()
227 assertTrue(executor.awaitTermination(1, TimeUnit.SECONDS)); in testDirectExecutorServiceServiceTermination()
228 assertTrue(executor.awaitTermination(0, TimeUnit.SECONDS)); in testDirectExecutorServiceServiceTermination()
520 shutdownFirst.verify(service).awaitTermination(2, TimeUnit.SECONDS); in testAddDelayedShutdownHook_success()
527 when(service.awaitTermination(2, TimeUnit.SECONDS)).thenThrow(new InterruptedException()); in testAddDelayedShutdownHook_interrupted()
640 when(service.awaitTermination(HALF_SECOND_NANOS, NANOSECONDS)).thenReturn(true); in testShutdownAndAwaitTermination_immediateShutdownInternal()
644 verify(service).awaitTermination(HALF_SECOND_NANOS, NANOSECONDS); in testShutdownAndAwaitTermination_immediateShutdownInternal()
649 when(service.awaitTermination(HALF_SECOND_NANOS, NANOSECONDS)) in testShutdownAndAwaitTermination_forcedShutDownInternal()
654 verify(service, times(2)).awaitTermination(HALF_SECOND_NANOS, NANOSECONDS); in testShutdownAndAwaitTermination_forcedShutDownInternal()
660 when(service.awaitTermination(HALF_SECOND_NANOS, NANOSECONDS)) in testShutdownAndAwaitTermination_nonTerminationInternal()
[all …]
|
| D | AtomicDoubleArrayTest.java | 212 awaitTermination(t); in testCompareAndSetInMultipleThreads()
326 awaitTermination(t1); in testCountingInMultipleThreads()
327 awaitTermination(t2); in testCountingInMultipleThreads()
|
| D | JSR166TestCase.java | 510 exec.awaitTermination(2 * LONG_DELAY_MS, MILLISECONDS)); in joinPool()
776 void awaitTermination(Thread t, long timeoutMillis) { in awaitTermination() method in JSR166TestCase
794 void awaitTermination(Thread t) { in awaitTermination() method in JSR166TestCase
795 awaitTermination(t, LONG_DELAY_MS); in awaitTermination()
|
| D | AbstractListeningExecutorServiceTest.java | 108 public boolean awaitTermination(long timeout, TimeUnit unit) { in awaitTermination() method in AbstractListeningExecutorServiceTest.TestListeningExecutorService
|
| D | WrappingExecutorServiceTest.java | 50 assertFalse(testExecutor.awaitTermination(10, TimeUnit.MILLISECONDS)); in testDelegations()
207 public boolean awaitTermination(long timeout, TimeUnit unit) { in awaitTermination() method in WrappingExecutorServiceTest.MockExecutor
|
| D | AbstractScheduledServiceTest.java | 171 assertTrue(executor.get().awaitTermination(100, TimeUnit.MILLISECONDS)); in testDefaultExecutorIsShutdownWhenServiceIsStopped()
198 assertTrue(executor.get().awaitTermination(100, TimeUnit.MILLISECONDS)); in testDefaultExecutorIsShutdownWhenServiceFails()
|
| /external/testng/src/main/java/org/testng/internal/thread/ |
| D | ExecutorAdapter.java | 39 public boolean awaitTermination(long timeout) { in awaitTermination() method in ExecutorAdapter
42 result= super.awaitTermination(timeout, TimeUnit.MILLISECONDS); in awaitTermination()
|
| D | IExecutor.java | 13 boolean awaitTermination(long timeout); in awaitTermination() method
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | MoreExecutors.java | 205 service.awaitTermination(terminationTimeout, timeUnit); in addDelayedShutdownHook()
343 public boolean awaitTermination(long timeout, TimeUnit unit) in awaitTermination() method in MoreExecutors.DirectExecutorService
523 public boolean awaitTermination(long timeout, TimeUnit unit) in awaitTermination() method in MoreExecutors.ListeningDecorator
525 return delegate.awaitTermination(timeout, unit); in awaitTermination()
948 if (!service.awaitTermination(halfTimeoutNanos, TimeUnit.NANOSECONDS)) {
952 service.awaitTermination(halfTimeoutNanos, TimeUnit.NANOSECONDS);
|
| D | ForwardingExecutorService.java | 48 public boolean awaitTermination(long timeout, TimeUnit unit) in awaitTermination() method in ForwardingExecutorService
50 return delegate().awaitTermination(timeout, unit); in awaitTermination()
|
| D | WrappingExecutorService.java | 162 public final boolean awaitTermination(long timeout, TimeUnit unit)
164 return delegate.awaitTermination(timeout, unit);
|
| /external/guice/extensions/servlet/test/com/google/inject/servlet/ |
| D | ContinuingRequestIntegrationTest.java | 79 public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
144 executor.awaitTermination(10, TimeUnit.SECONDS); in testRequestContinuesInOtherThread()
186 executor.awaitTermination(10, TimeUnit.SECONDS); in testRequestContinuationDiesInHttpRequestThread()
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | AbstractListenableFutureTest.java | 200 exec.awaitTermination(100, TimeUnit.MILLISECONDS); in testListenersNotifiedOnError()
244 exec.awaitTermination(500, TimeUnit.MILLISECONDS); in testAllListenersCompleteSuccessfully()
|
| D | SameThreadScheduledExecutorService.java | 74 public boolean awaitTermination(long timeout, TimeUnit unit) in awaitTermination() method in SameThreadScheduledExecutorService
77 return delegate.awaitTermination(timeout, unit); in awaitTermination()
|
| D | TestingExecutors.java | 124 @Override public boolean awaitTermination(long timeout, TimeUnit unit) { in awaitTermination() method in TestingExecutors.NoOpScheduledExecutorService
|
| /external/testng/src/main/java/org/testng/remote/adapter/ |
| D | IMasterAdapter.java | 39 public void awaitTermination(long timeout) throws InterruptedException; in awaitTermination() method
|
| D | DefaultMastertAdapter.java | 80 public void awaitTermination(long timeout) throws InterruptedException in awaitTermination() method in DefaultMastertAdapter
|
| /external/guava/guava-bootstrap/src/java/util/concurrent/ |
| D | ExecutorService.java | 25 boolean awaitTermination(long timeout, TimeUnit unit) in awaitTermination() method
|
| /external/jmdns/src/javax/jmdns/impl/ |
| D | JmmDNSImpl.java | 106 executor.awaitTermination(DNSConstants.CLOSE_TIMEOUT, TimeUnit.MILLISECONDS); in close()
215 executor.awaitTermination(timeout, TimeUnit.MILLISECONDS); in getServiceInfos()
418 executor.awaitTermination(timeout, TimeUnit.MILLISECONDS); in list()
|
| /external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/util/ |
| D | RobolectricBackgroundExecutorService.java | 37 public boolean awaitTermination(long l, TimeUnit timeUnit) throws InterruptedException { in awaitTermination() method in RobolectricBackgroundExecutorService
|
| /external/jetty/src/java/org/eclipse/jetty/util/thread/ |
| D | ExecutorThreadPool.java | 174 _executor.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
|
| /external/junit/src/org/junit/internal/runners/ |
| D | MethodRoadie.java | 69 boolean terminated= service.awaitTermination(timeout, in runWithTimeout()
|
| /external/owasp/sanitizer/src/tests/org/owasp/html/ |
| D | HtmlSanitizerFuzzerTest.java | 142 executor.awaitTermination(runCount * 4, TimeUnit.SECONDS); in testFuzzHtmlParser()
|
| /external/testng/src/main/java/org/testng/remote/ |
| D | SuiteDispatcher.java | 140 m_masterAdpter.awaitTermination(100000); in dispatch()
|
| /external/vogar/src/vogar/tasks/ |
| D | TaskQueue.java | 79 runners.awaitTermination(FOREVER, TimeUnit.SECONDS); in runTasks()
|