/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()
|
/external/grpc-grpc-java/core/src/main/java/io/grpc/ |
D | Server.java | 129 public abstract boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException; in awaitTermination() method in Server 136 public abstract void awaitTermination() throws InterruptedException; in awaitTermination() method in Server
|
D | ManagedChannel.java | 71 public abstract boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException; in awaitTermination() method in ManagedChannel
|
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
D | ForwardingManagedChannelTest.java | 80 public void awaitTermination() throws Exception { in awaitTermination() method in ForwardingManagedChannelTest 83 forward.awaitTermination(timeout, unit); in awaitTermination() 84 verify(mock).awaitTermination(eq(timeout), eq(unit)); in awaitTermination()
|
/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/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
D | ForwardingManagedChannel.java | 56 public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { in awaitTermination() method in ForwardingManagedChannel 57 return delegate.awaitTermination(timeout, unit); in awaitTermination()
|
D | ManagedChannelOrphanWrapper.java | 69 public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { in awaitTermination() method in ManagedChannelOrphanWrapper 70 boolean ret = super.awaitTermination(timeout, unit); in awaitTermination()
|
/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/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
D | GrpcServerRule.java | 103 channel.awaitTermination(1, TimeUnit.MINUTES); in after() 104 server.awaitTermination(1, TimeUnit.MINUTES); in after()
|
D | GrpcCleanupRule.java | 218 return channel.awaitTermination(duration, timeUnit); 246 return server.awaitTermination(duration, timeUnit);
|
/external/mockito/src/test/java/org/mockitousage/bugs/ |
D | ShouldNotDeadlockAnswerExecutionTest.java | 41 if (!threads.awaitTermination(1000, TimeUnit.MILLISECONDS)) { in failIfMockIsSharedBetweenThreads() 68 if (!threads.awaitTermination(500, TimeUnit.MILLISECONDS)) { in successIfEveryThreadHasItsOwnMock()
|
/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/ |
D | TransportBenchmark.java | 162 channel.awaitTermination(1, TimeUnit.SECONDS); in tearDown() 163 server.awaitTermination(1, TimeUnit.SECONDS); in tearDown() 172 groupToShutdown.awaitTermination(1, TimeUnit.SECONDS); in tearDown()
|
/external/guice/extensions/servlet/test/com/google/inject/servlet/ |
D | ContinuingRequestIntegrationTest.java | 79 public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { 148 executor.awaitTermination(10, TimeUnit.SECONDS); in testRequestContinuesInOtherThread() 191 executor.awaitTermination(10, TimeUnit.SECONDS); in testRequestContinuationDiesInHttpRequestThread()
|
/external/grpc-grpc-java/netty/shaded/src/testShadow/java/io/grpc/netty/shaded/ |
D | ShadingTest.java | 53 channel.awaitTermination(1, TimeUnit.SECONDS); in tearDown() 57 server.awaitTermination(1, TimeUnit.SECONDS); in tearDown()
|
/external/robolectric-shadows/robolectric/src/test/java/org/robolectric/android/util/concurrent/ |
D | RoboExecutorServiceTest.java | 123 assertThat(executorService.awaitTermination(0, TimeUnit.MILLISECONDS)).isTrue(); in whenAwaitingTerminationAfterShutdown_TrueIsReturned() 130 assertThat(executorService.awaitTermination(500, TimeUnit.MILLISECONDS)).isFalse(); in whenAwaitingTermination_AllTasksAreRunByDefault()
|
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
D | TestServiceServer.java | 162 if (!server.awaitTermination(5, TimeUnit.SECONDS)) { in stop() 176 server.awaitTermination(); in blockUntilShutdown()
|
/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()
|
/external/testng/src/main/java/org/testng/remote/adapter/ |
D | IMasterAdapter.java | 39 public void awaitTermination(long timeout) throws InterruptedException; in awaitTermination() method
|
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
D | MoreInProcessTest.java | 71 assertTrue(inProcessChannel.awaitTermination(900, TimeUnit.MILLISECONDS)); in tearDown() 72 assertTrue(inProcessServer.awaitTermination(900, TimeUnit.MILLISECONDS)); in tearDown()
|