Home
last modified time | relevance | path

Searched refs:awaitTermination (Results 1 – 25 of 117) sorted by relevance

12345

/external/guava/guava-tests/test/com/google/common/util/concurrent/
DMoreExecutorsTest.java223 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 …]
DAtomicDoubleArrayTest.java212 awaitTermination(t); in testCompareAndSetInMultipleThreads()
326 awaitTermination(t1); in testCountingInMultipleThreads()
327 awaitTermination(t2); in testCountingInMultipleThreads()
DJSR166TestCase.java510 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/
DServer.java129 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
DManagedChannel.java71 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/
DForwardingManagedChannelTest.java80 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/
DExecutorAdapter.java39 public boolean awaitTermination(long timeout) { in awaitTermination() method in ExecutorAdapter
42 result= super.awaitTermination(timeout, TimeUnit.MILLISECONDS); in awaitTermination()
DIExecutor.java13 boolean awaitTermination(long timeout); in awaitTermination() method
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DForwardingManagedChannel.java56 public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { in awaitTermination() method in ForwardingManagedChannel
57 return delegate.awaitTermination(timeout, unit); in awaitTermination()
DManagedChannelOrphanWrapper.java69 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/
DMoreExecutors.java205 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);
DForwardingExecutorService.java48 public boolean awaitTermination(long timeout, TimeUnit unit) in awaitTermination() method in ForwardingExecutorService
50 return delegate().awaitTermination(timeout, unit); in awaitTermination()
DWrappingExecutorService.java162 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/
DGrpcServerRule.java103 channel.awaitTermination(1, TimeUnit.MINUTES); in after()
104 server.awaitTermination(1, TimeUnit.MINUTES); in after()
DGrpcCleanupRule.java218 return channel.awaitTermination(duration, timeUnit);
246 return server.awaitTermination(duration, timeUnit);
/external/mockito/src/test/java/org/mockitousage/bugs/
DShouldNotDeadlockAnswerExecutionTest.java41 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/
DTransportBenchmark.java162 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/
DContinuingRequestIntegrationTest.java79 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/
DShadingTest.java53 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/
DRoboExecutorServiceTest.java123 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/
DTestServiceServer.java162 if (!server.awaitTermination(5, TimeUnit.SECONDS)) { in stop()
176 server.awaitTermination(); in blockUntilShutdown()
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/
DAbstractListenableFutureTest.java200 exec.awaitTermination(100, TimeUnit.MILLISECONDS); in testListenersNotifiedOnError()
244 exec.awaitTermination(500, TimeUnit.MILLISECONDS); in testAllListenersCompleteSuccessfully()
DSameThreadScheduledExecutorService.java74 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/
DIMasterAdapter.java39 public void awaitTermination(long timeout) throws InterruptedException; in awaitTermination() method
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DMoreInProcessTest.java71 assertTrue(inProcessChannel.awaitTermination(900, TimeUnit.MILLISECONDS)); in tearDown()
72 assertTrue(inProcessServer.awaitTermination(900, TimeUnit.MILLISECONDS)); in tearDown()

12345