| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | CyclicBarrierTest.java | 86 b.await(); in testSingleParty()
87 b.await(); in testSingleParty()
99 b.await(); in testBarrierAction()
100 b.await(); in testBarrierAction()
112 b.await(); in testTwoParties()
113 b.await(); in testTwoParties()
114 b.await(); in testTwoParties()
115 b.await(); in testTwoParties()
118 b.await(); in testTwoParties()
119 b.await(); in testTwoParties()
[all …]
|
| D | CountDownLatchTest.java | 72 l.await(); in testAwait()
76 await(pleaseCountDown); in testAwait()
97 assertTrue(l.await(LONG_DELAY_MS, MILLISECONDS)); in testTimedAwait()
101 await(pleaseCountDown); in testTimedAwait()
121 l.await(); in testAwait_Interruptible()
128 l.await(); in testAwait_Interruptible()
136 await(pleaseInterrupt); in testAwait_Interruptible()
152 l.await(LONG_DELAY_MS, MILLISECONDS); in testTimedAwait_Interruptible()
159 l.await(LONG_DELAY_MS, MILLISECONDS); in testTimedAwait_Interruptible()
167 await(pleaseInterrupt); in testTimedAwait_Interruptible()
[all …]
|
| D | ReentrantLockTest.java | 151 enum AwaitMethod { await, awaitTimed, awaitNanos, awaitUntil } enumConstant
156 void await(Condition c, AwaitMethod awaitMethod) in await() method in ReentrantLockTest
160 case await: in await()
161 c.await(); in await()
164 assertTrue(c.await(timeoutMillis, MILLISECONDS)); in await()
459 barrier.await(); in testIsLocked()
460 barrier.await(); in testIsLocked()
464 barrier.await(); in testIsLocked()
466 barrier.await(); in testIsLocked()
503 await(c, awaitMethod); in testAwait_IMSE()
[all …]
|
| D | ScheduledExecutorTest.java | 59 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS)); in testExecute()
80 assertTrue(done.await(0L, MILLISECONDS)); in testSchedule1()
98 await(done); in testSchedule3()
120 await(done); in testSchedule4()
142 await(done); in testSchedule5()
170 await(done, totalDelayMillis + LONG_DELAY_MS); in testFixedRateSequence()
216 await(done, totalDelayMillis + cycles * LONG_DELAY_MS); in testFixedDelaySequence()
349 await(done); in testGetActiveCount()
351 await(threadStarted); in testGetActiveCount()
371 threadProceed.await(); in testGetCompletedTaskCount()
[all …]
|
| D | ExchangerTest.java | 84 await(threadStarted); in testExchange_InterruptedException()
101 await(threadStarted); in testTimedExchange_InterruptedException()
141 interrupted.await(); in testReplacementAfterExchange()
146 interrupted.await(); in testReplacementAfterExchange()
150 await(exchanged); in testReplacementAfterExchange()
|
| D | ScheduledExecutorSubclassTest.java | 116 await(done); in testExecute()
154 await(done); in testSchedule3()
176 await(done); in testSchedule4()
198 await(done); in testSchedule5()
226 await(done, totalDelayMillis + LONG_DELAY_MS); in testFixedRateSequence()
272 await(done, totalDelayMillis + cycles * LONG_DELAY_MS); in testFixedDelaySequence()
405 await(done); in testGetActiveCount()
407 await(threadStarted); in testGetActiveCount()
427 threadProceed.await(); in testGetCompletedTaskCount()
430 await(threadStarted); in testGetCompletedTaskCount()
[all …]
|
| D | ThreadPoolExecutorTest.java | 100 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS)); in testExecute()
121 await(done); in testGetActiveCount()
123 await(threadStarted); in testGetActiveCount()
194 threadProceed.await(); in testGetCompletedTaskCount()
197 await(threadStarted); in testGetCompletedTaskCount()
200 threadDone.await(); in testGetCompletedTaskCount()
348 await(done); in testGetLargestPoolSize()
351 await(threadsStarted); in testGetLargestPoolSize()
392 await(done); in testGetPoolSize()
394 await(threadStarted); in testGetPoolSize()
[all …]
|
| D | DoubleAdderTest.java | 144 barrier.await(); in testAddAndSumMT()
145 barrier.await(); in testAddAndSumMT()
165 barrier.await(); in run()
170 barrier.await(); in run()
|
| D | ReentrantReadWriteLockTest.java | 160 enum AwaitMethod { await, awaitTimed, awaitNanos, awaitUntil } enumConstant
165 void await(Condition c, AwaitMethod awaitMethod) in await() method in ReentrantReadWriteLockTest
169 case await: in await()
170 c.await(); in await()
173 assertTrue(c.await(timeoutMillis, MILLISECONDS)); in await()
888 await(c, awaitMethod); in testAwait_IMSE()
960 assertFalse(c.await(timeoutMillis, MILLISECONDS));
1000 c.await(); in testAwait()
1004 await(locked); in testAwait()
1045 await(pleaseInterrupt); in testAwaitUninterruptibly()
[all …]
|
| D | ThreadPoolExecutorSubclassTest.java | 123 cond.await(); in get()
247 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS)); in testExecute()
268 await(done); in testGetActiveCount()
270 await(threadStarted); in testGetActiveCount()
341 threadProceed.await(); in testGetCompletedTaskCount()
344 await(threadStarted); in testGetCompletedTaskCount()
347 threadDone.await(); in testGetCompletedTaskCount()
495 await(done); in testGetLargestPoolSize()
498 await(threadsStarted); in testGetLargestPoolSize()
539 await(done); in testGetPoolSize()
[all …]
|
| D | LongAdderTest.java | 167 barrier.await(); in testAddAndSumMT()
168 barrier.await(); in testAddAndSumMT()
188 barrier.await(); in run()
193 barrier.await(); in run()
|
| D | LinkedBlockingDequeTest.java | 600 await(pleaseInterrupt); in testBlockingPut()
631 await(pleaseTake); in testPutWithTake()
635 await(pleaseInterrupt); in testPutWithTake()
662 await(pleaseInterrupt); in testTimedOffer()
705 await(pleaseInterrupt); in testBlockingTake()
771 aboutToWait.await(); in testInterruptedTimedPoll()
830 await(pleaseInterrupt); in testBlockingPutFirst()
861 await(pleaseTake); in testPutFirstWithTake()
865 await(pleaseInterrupt); in testPutFirstWithTake()
892 await(pleaseInterrupt); in testTimedOfferFirst()
[all …]
|
| D | BlockingQueueTest.java | 225 barrier.await(); in testTimedPollWithOffer()
236 barrier.await(); in testTimedPollWithOffer()
246 barrier.await(); in testTimedPollWithOffer()
251 barrier.await(); in testTimedPollWithOffer()
273 await(threadStarted);
314 await(threadStarted);
|
| D | SynchronousQueueTest.java | 147 await(pleaseInterrupt); in testBlockingPut()
176 await(pleaseTake); in testPutWithTake()
181 await(pleaseInterrupt); in testPutWithTake()
208 await(pleaseInterrupt); in testTimedOffer()
285 await(pleaseOffer); in testTimedPollWithOffer()
291 await(pleaseInterrupt); in testTimedPollWithOffer()
487 threadsStarted.await();
494 threadsStarted.await();
513 threadsStarted.await();
520 threadsStarted.await();
|
| D | AbstractQueuedSynchronizerTest.java | 213 enum AwaitMethod { await, awaitTimed, awaitNanos, awaitUntil } enumConstant
218 void await(ConditionObject c, AwaitMethod awaitMethod) in await() method in AbstractQueuedSynchronizerTest
222 case await: in await()
223 c.await(); in await()
226 assertTrue(c.await(timeoutMillis, MILLISECONDS)); in await()
252 assertFalse(c.await(timeoutMillis, MILLISECONDS)); in assertAwaitTimesOut()
629 await(c, awaitMethod); in testAwait_IMSE()
679 public void testSignal_await() { testSignal(AwaitMethod.await); }
691 await(c, awaitMethod);
833 c.await();
[all …]
|
| D | AbstractQueuedLongSynchronizerTest.java | 210 enum AwaitMethod { await, awaitTimed, awaitNanos, awaitUntil } enumConstant
215 void await(ConditionObject c, AwaitMethod awaitMethod) in await() method in AbstractQueuedLongSynchronizerTest
219 case await: in await()
220 c.await(); in await()
223 assertTrue(c.await(timeoutMillis, MILLISECONDS)); in await()
249 assertFalse(c.await(timeoutMillis, MILLISECONDS)); in assertAwaitTimesOut()
626 await(c, awaitMethod); in testAwait_IMSE()
676 public void testSignal_await() { testSignal(AwaitMethod.await); }
688 await(c, awaitMethod);
830 c.await();
[all …]
|
| D | LockSupportTest.java | 124 await(pleaseUnpark); in testParkBeforeUnpark()
161 await(pleaseUnpark); in testParkAfterUnpark()
199 await(pleaseInterrupt); in testParkBeforeInterrupt()
239 await(pleaseInterrupt); in testParkAfterInterrupt()
312 await(started); in testGetBlocker()
|
| D | FutureTaskTest.java | 428 await(pleaseCancel); in testCancelInterrupt()
452 await(cancelled); in testCancelInterrupt_ThrowsSecurityException()
464 await(pleaseCancel); in testCancelInterrupt_ThrowsSecurityException()
504 await(pleaseCancel); in testCancelInterrupt_taskFails()
525 await(cancelled); in testCancelNoInterrupt()
531 await(pleaseCancel); in testCancelNoInterrupt()
567 await(pleaseRun); in testGetRun()
606 await(pleaseSet); in testGetSet()
642 await(cancelled); in testTimedGet_Cancellation()
661 await(pleaseCancel); in testTimedGet_Cancellation()
[all …]
|
| D | LinkedBlockingQueueTest.java | 292 await(pleaseInterrupt); in testBlockingPut()
323 await(pleaseTake); in testPutWithTake()
327 await(pleaseInterrupt); in testPutWithTake()
354 await(pleaseInterrupt); in testTimedOffer()
397 await(pleaseInterrupt); in testBlockingTake()
463 await(aboutToWait); in testInterruptedTimedPoll()
736 threadsStarted.await(); in testOfferInExecutor()
743 threadsStarted.await(); in testOfferInExecutor()
760 threadsStarted.await(); in testPollInExecutor()
767 threadsStarted.await(); in testPollInExecutor()
|
| D | PhaserTest.java | 498 await(pleaseInterrupt);
529 await(pleaseArrive);
557 await(pleaseArrive);
586 await(pleaseArrive);
611 await(pleaseInterrupt);
660 await(latch);
664 await(latch);
741 await(pleaseForceTermination);
780 await(pleaseArrive);
|
| /libcore/ojluni/src/main/java/java/util/concurrent/locks/ |
| D | Condition.java | 232 void await() throws InterruptedException; in await() method
374 boolean await(long time, TimeUnit unit) throws InterruptedException; in await() method
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | CountDownLatch.java | 231 public void await() throws InterruptedException { in await() method in CountDownLatch
276 public boolean await(long timeout, TimeUnit unit) in await() method in CountDownLatch
|
| D | CyclicBarrier.java | 235 trip.await(); in dowait()
361 public int await() throws InterruptedException, BrokenBarrierException { in await() method in CyclicBarrier
432 public int await(long timeout, TimeUnit unit) in await() method in CyclicBarrier
|
| /libcore/luni/src/test/java/libcore/java/net/ |
| D | ServerSocketConcurrentCloseTest.java | 82 boolean completed = threadFinishedLatch.await(5, TimeUnit.SECONDS); in testImplAccept_detectsClosedState()
212 return startLatch.await(timeout, timeUnit); in awaitStart()
249 return startLatch.await(timeout, timeUnit); in awaitStart()
253 return shutdownLatch.await(timeout, timeUnit); in awaitShutdown()
|
| D | SocketTimeoutTest.java | 137 assertTrue(threadStarted.await(500, TimeUnit.MILLISECONDS)); in testSocketWriteNeverTimeouts()
142 !writeCompleted.await(TIMEOUT_MILLIS * 2, TimeUnit.MILLISECONDS); in testSocketWriteNeverTimeouts()
147 assertTrue(writeCompleted.await(5000, TimeUnit.MILLISECONDS)); in testSocketWriteNeverTimeouts()
|