| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | CyclicBarrierTest.java | 75 b.await(); in testSingleParty()
76 b.await(); in testSingleParty()
88 b.await(); in testBarrierAction()
89 b.await(); in testBarrierAction()
101 b.await(); in testTwoParties()
102 b.await(); in testTwoParties()
103 b.await(); in testTwoParties()
104 b.await(); in testTwoParties()
107 b.await(); in testTwoParties()
108 b.await(); in testTwoParties()
[all …]
|
| D | CountDownLatchTest.java | 61 l.await(); in testAwait()
65 await(pleaseCountDown); in testAwait()
86 assertTrue(l.await(LONG_DELAY_MS, MILLISECONDS)); in testTimedAwait()
90 await(pleaseCountDown); in testTimedAwait()
110 l.await(); in testAwait_Interruptible()
117 l.await(); in testAwait_Interruptible()
125 await(pleaseInterrupt); in testAwait_Interruptible()
141 l.await(LONG_DELAY_MS, MILLISECONDS); in testTimedAwait_Interruptible()
148 l.await(LONG_DELAY_MS, MILLISECONDS); in testTimedAwait_Interruptible()
156 await(pleaseInterrupt); in testTimedAwait_Interruptible()
[all …]
|
| D | ReentrantLockTest.java | 136 enum AwaitMethod { await, awaitTimed, awaitNanos, awaitUntil }; enumConstant
141 void await(Condition c, AwaitMethod awaitMethod) in await() method in ReentrantLockTest
145 case await: in await()
146 c.await(); in await()
149 assertTrue(c.await(timeoutMillis, MILLISECONDS)); in await()
441 barrier.await(); in testIsLocked()
442 barrier.await(); in testIsLocked()
446 barrier.await(); in testIsLocked()
448 barrier.await(); in testIsLocked()
489 await(c, awaitMethod); in testAwait_IMSE()
[all …]
|
| D | ExchangerTest.java | 72 await(threadStarted); in testExchange_InterruptedException()
89 await(threadStarted); in testTimedExchange_InterruptedException()
129 interrupted.await(); in testReplacementAfterExchange()
134 interrupted.await(); in testReplacementAfterExchange()
138 await(exchanged); in testReplacementAfterExchange()
|
| D | ScheduledExecutorTest.java | 31 assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); in testExecute()
54 assertTrue(done.await(0L, MILLISECONDS)); in testSchedule1()
74 await(done); in testSchedule3()
98 await(done); in testSchedule4()
122 await(done); in testSchedule5()
291 done.await(); in testGetActiveCount()
293 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetActiveCount()
316 threadProceed.await(); in testGetCompletedTaskCount()
319 await(threadStarted); in testGetCompletedTaskCount()
322 threadDone.await(); in testGetCompletedTaskCount()
[all …]
|
| D | ThreadPoolExecutorTest.java | 71 assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); in testExecute()
94 done.await(); in testGetActiveCount()
96 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetActiveCount()
156 threadProceed.await(); in testGetCompletedTaskCount()
159 await(threadStarted); in testGetCompletedTaskCount()
162 threadDone.await(); in testGetCompletedTaskCount()
308 done.await(); in testGetLargestPoolSize()
311 assertTrue(threadsStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetLargestPoolSize()
350 done.await(); in testGetPoolSize()
352 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetPoolSize()
[all …]
|
| D | ScheduledExecutorSubclassTest.java | 83 assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); in testExecute()
106 assertTrue(done.await(0L, MILLISECONDS)); in testSchedule1()
126 await(done); in testSchedule3()
150 await(done); in testSchedule4()
174 await(done); in testSchedule5()
341 done.await(); in testGetActiveCount()
343 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetActiveCount()
366 threadProceed.await(); in testGetCompletedTaskCount()
369 await(threadStarted); in testGetCompletedTaskCount()
372 threadDone.await(); in testGetCompletedTaskCount()
[all …]
|
| D | LinkedBlockingDequeTest.java | 573 await(pleaseInterrupt); in testBlockingPut()
604 await(pleaseTake); in testPutWithTake()
608 await(pleaseInterrupt); in testPutWithTake()
635 await(pleaseInterrupt); in testTimedOffer()
678 await(pleaseInterrupt); in testBlockingTake()
746 aboutToWait.await(); in testInterruptedTimedPoll()
805 await(pleaseInterrupt); in testBlockingPutFirst()
836 await(pleaseTake); in testPutFirstWithTake()
840 await(pleaseInterrupt); in testPutFirstWithTake()
867 await(pleaseInterrupt); in testTimedOfferFirst()
[all …]
|
| D | ReentrantReadWriteLockTest.java | 145 enum AwaitMethod { await, awaitTimed, awaitNanos, awaitUntil }; enumConstant
150 void await(Condition c, AwaitMethod awaitMethod) in await() method in ReentrantReadWriteLockTest
153 case await: in await()
154 c.await(); in await()
157 assertTrue(c.await(2 * LONG_DELAY_MS, MILLISECONDS)); in await()
873 await(c, awaitMethod); in testAwait_IMSE()
945 assertFalse(c.await(timeoutMillis, MILLISECONDS));
989 c.await(); in testAwait()
993 await(locked); in testAwait()
1034 await(pleaseInterrupt); in testAwaitUninterruptibly()
[all …]
|
| D | BlockingQueueTest.java | 213 barrier.await(); in testTimedPollWithOffer()
224 barrier.await(); in testTimedPollWithOffer()
232 barrier.await(); in testTimedPollWithOffer()
237 barrier.await(); in testTimedPollWithOffer()
259 await(threadStarted);
300 await(threadStarted);
|
| D | LockSupportTest.java | 106 await(pleaseUnpark); in testParkBeforeUnpark()
143 await(pleaseUnpark); in testParkAfterUnpark()
181 await(pleaseInterrupt); in testParkBeforeInterrupt()
221 await(pleaseInterrupt); in testParkAfterInterrupt()
294 await(started); in testGetBlocker()
|
| D | SynchronousQueueTest.java | 119 await(pleaseInterrupt); in testBlockingPut()
148 await(pleaseTake); in testPutWithTake()
153 await(pleaseInterrupt); in testPutWithTake()
180 await(pleaseInterrupt); in testTimedOffer()
256 await(pleaseOffer); in testTimedPollWithOffer()
262 await(pleaseInterrupt); in testTimedPollWithOffer()
463 threadsStarted.await();
470 threadsStarted.await();
489 threadsStarted.await();
496 threadsStarted.await();
|
| D | ThreadPoolExecutorSubclassTest.java | 88 cond.await(); in get()
211 assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); in testExecute()
234 done.await(); in testGetActiveCount()
236 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetActiveCount()
290 threadProceed.await(); in testGetCompletedTaskCount()
293 await(threadStarted); in testGetCompletedTaskCount()
296 threadDone.await(); in testGetCompletedTaskCount()
415 done.await(); in testGetLargestPoolSize()
418 assertTrue(threadsStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetLargestPoolSize()
454 done.await(); in testGetPoolSize()
[all …]
|
| D | AbstractQueuedLongSynchronizerTest.java | 194 enum AwaitMethod { await, awaitTimed, awaitNanos, awaitUntil }; enumConstant
199 void await(ConditionObject c, AwaitMethod awaitMethod) in await() method in AbstractQueuedLongSynchronizerTest
203 case await: in await()
204 c.await(); in await()
207 assertTrue(c.await(timeoutMillis, MILLISECONDS)); in await()
230 assertFalse(c.await(timeoutMillis, MILLISECONDS)); in assertAwaitTimesOut()
600 await(c, awaitMethod); in testAwait_IMSE()
650 public void testSignal_await() { testSignal(AwaitMethod.await); }
662 await(c, awaitMethod);
804 c.await();
[all …]
|
| D | AbstractQueuedSynchronizerTest.java | 197 enum AwaitMethod { await, awaitTimed, awaitNanos, awaitUntil }; enumConstant
202 void await(ConditionObject c, AwaitMethod awaitMethod) in await() method in AbstractQueuedSynchronizerTest
206 case await: in await()
207 c.await(); in await()
210 assertTrue(c.await(timeoutMillis, MILLISECONDS)); in await()
233 assertFalse(c.await(timeoutMillis, MILLISECONDS)); in assertAwaitTimesOut()
603 await(c, awaitMethod); in testAwait_IMSE()
653 public void testSignal_await() { testSignal(AwaitMethod.await); }
665 await(c, awaitMethod);
807 c.await();
[all …]
|
| D | FutureTaskTest.java | 410 await(pleaseCancel); in testCancelInterrupt()
434 await(cancelled); in testCancelInterrupt_ThrowsSecurityException()
446 await(pleaseCancel); in testCancelInterrupt_ThrowsSecurityException()
486 await(pleaseCancel); in testCancelInterrupt_taskFails()
507 await(cancelled); in testCancelNoInterrupt()
513 await(pleaseCancel); in testCancelNoInterrupt()
549 await(pleaseRun); in testGetRun()
588 await(pleaseSet); in testGetSet()
624 await(cancelled); in testTimedGet_Cancellation()
643 await(pleaseCancel); in testTimedGet_Cancellation()
[all …]
|
| D | LinkedBlockingQueueTest.java | 263 await(pleaseInterrupt); in testBlockingPut()
294 await(pleaseTake); in testPutWithTake()
298 await(pleaseInterrupt); in testPutWithTake()
325 await(pleaseInterrupt); in testTimedOffer()
368 await(pleaseInterrupt); in testBlockingTake()
436 aboutToWait.await(); in testInterruptedTimedPoll()
693 threadsStarted.await(); in testOfferInExecutor()
700 threadsStarted.await(); in testOfferInExecutor()
717 threadsStarted.await(); in testPollInExecutor()
724 threadsStarted.await(); in testPollInExecutor()
|
| D | PhaserTest.java | 487 await(pleaseInterrupt);
518 await(pleaseArrive);
546 await(pleaseArrive);
575 await(pleaseInterrupt);
600 await(pleaseInterrupt);
649 await(latch);
653 await(latch);
730 await(pleaseForceTermination);
769 await(pleaseArrive);
|
| D | ExecutorsTest.java | 179 await(proceed); in testNewSingleThreadScheduledExecutor()
205 await(proceed); in testNewScheduledThreadPool()
233 await(proceed); in testUnconfigurableScheduledExecutorService()
310 await(done); in testDefaultThreadFactory()
351 await(done); in testPrivilegedThreadFactory()
|
| D | ArrayBlockingQueueTest.java | 273 await(pleaseInterrupt); in testBlockingPut()
304 await(pleaseTake); in testPutWithTake()
308 await(pleaseInterrupt); in testPutWithTake()
335 await(pleaseInterrupt); in testTimedOffer()
378 await(pleaseInterrupt); in testBlockingTake()
447 aboutToWait.await(); in testInterruptedTimedPoll()
759 threadsStarted.await(); in testOfferInExecutor()
766 threadsStarted.await(); in testOfferInExecutor()
784 threadsStarted.await(); in testPollInExecutor()
791 threadsStarted.await(); in testPollInExecutor()
|
| D | JSR166TestCase.java | 787 latch.await(); in latchAwaitingStringTask()
796 await(latch);
800 public void await(CountDownLatch latch) {
802 assertTrue(latch.await(LONG_DELAY_MS, MILLISECONDS));
808 public void await(Semaphore semaphore) {
1043 public int await() {
1045 return super.await(2 * LONG_DELAY_MS, MILLISECONDS);
|
| D | LinkedTransferQueueTest.java | 214 await(pleaseInterrupt); in testBlockingTake()
284 aboutToWait.await(); in testInterruptedTimedPoll()
573 threadsStarted.await(); in testOfferInExecutor()
579 threadsStarted.await(); in testOfferInExecutor()
598 threadsStarted.await(); in testPollInExecutor()
605 threadsStarted.await(); in testPollInExecutor()
713 threadStarted.await(); in testWaitingConsumer()
752 threadStarted.await(); in testTransfer2()
930 await(pleaseInterrupt); in testTryTransfer5()
|
| /libcore/luni/src/main/java/java/util/concurrent/locks/ |
| D | Condition.java | 202 void await() throws InterruptedException; in await() method
344 boolean await(long time, TimeUnit unit) throws InterruptedException; in await() method
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| D | CountDownLatch.java | 201 public void await() throws InterruptedException { in await() method in CountDownLatch
246 public boolean await(long timeout, TimeUnit unit) in await() method in CountDownLatch
|
| D | CyclicBarrier.java | 201 trip.await(); in dowait()
327 public int await() throws InterruptedException, BrokenBarrierException { in await() method in CyclicBarrier
397 public int await(long timeout, TimeUnit unit) in await() method in CyclicBarrier
|