| /libcore/ojluni/src/test/java/util/concurrent/tck/ |
| D | CyclicBarrierTest.java | 105 b.await(); in testSingleParty()
106 b.await(); in testSingleParty()
120 b.await(); in testBarrierAction()
121 b.await(); in testBarrierAction()
133 b.await(); in testTwoParties()
134 b.await(); in testTwoParties()
135 b.await(); in testTwoParties()
136 b.await(); in testTwoParties()
139 b.await(); in testTwoParties()
140 b.await(); in testTwoParties()
[all …]
|
| D | CountDownLatchTest.java | 95 l.await(); in testAwait()
99 await(pleaseCountDown); in testAwait()
120 assertTrue(l.await(LONG_DELAY_MS, MILLISECONDS)); in testTimedAwait()
124 await(pleaseCountDown); in testTimedAwait()
144 l.await(); in testAwait_Interruptible()
151 l.await(); in testAwait_Interruptible()
159 await(pleaseInterrupt); in testAwait_Interruptible()
175 l.await(LONG_DELAY_MS, MILLISECONDS); in testTimedAwait_Interruptible()
182 l.await(LONG_DELAY_MS, MILLISECONDS); in testTimedAwait_Interruptible()
190 await(pleaseInterrupt); in testTimedAwait_Interruptible()
[all …]
|
| D | ReentrantLockTest.java | 174 enum AwaitMethod { await, awaitTimed, awaitNanos, awaitUntil } enumConstant
179 void await(Condition c, AwaitMethod awaitMethod) in await() method in ReentrantLockTest
183 case await: in await()
184 c.await(); in await()
187 assertTrue(c.await(timeoutMillis, MILLISECONDS)); in await()
482 barrier.await(); in testIsLocked()
483 barrier.await(); in testIsLocked()
487 barrier.await(); in testIsLocked()
489 barrier.await(); in testIsLocked()
526 await(c, awaitMethod); in testAwait_IMSE()
[all …]
|
| D | ScheduledExecutorTest.java | 83 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS)); in testExecute()
104 assertTrue(done.await(0L, MILLISECONDS)); in testSchedule1()
122 await(done); in testSchedule3()
144 await(done); in testSchedule4()
166 await(done); in testSchedule5()
194 await(done, totalDelayMillis + LONG_DELAY_MS); in testFixedRateSequence()
240 await(done, totalDelayMillis + cycles * LONG_DELAY_MS); in testFixedDelaySequence()
373 await(done); in testGetActiveCount()
375 await(threadStarted); in testGetActiveCount()
395 threadProceed.await(); in testGetCompletedTaskCount()
[all …]
|
| D | ScheduledExecutorSubclassTest.java | 140 await(done); in testExecute()
178 await(done); in testSchedule3()
200 await(done); in testSchedule4()
222 await(done); in testSchedule5()
250 await(done, totalDelayMillis + LONG_DELAY_MS); in testFixedRateSequence()
296 await(done, totalDelayMillis + cycles * LONG_DELAY_MS); in testFixedDelaySequence()
429 await(done); in testGetActiveCount()
431 await(threadStarted); in testGetActiveCount()
451 threadProceed.await(); in testGetCompletedTaskCount()
454 await(threadStarted); in testGetCompletedTaskCount()
[all …]
|
| D | ExchangerTest.java | 107 await(threadStarted); in testExchange_InterruptedException()
124 await(threadStarted); in testTimedExchange_InterruptedException()
164 interrupted.await(); in testReplacementAfterExchange()
169 interrupted.await(); in testReplacementAfterExchange()
173 await(exchanged); in testReplacementAfterExchange()
|
| D | ThreadPoolExecutorTest.java | 122 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS)); in testExecute()
143 await(done); in testGetActiveCount()
145 await(threadStarted); in testGetActiveCount()
216 threadProceed.await(); in testGetCompletedTaskCount()
219 await(threadStarted); in testGetCompletedTaskCount()
222 threadDone.await(); in testGetCompletedTaskCount()
370 await(done); in testGetLargestPoolSize()
373 await(threadsStarted); in testGetLargestPoolSize()
414 await(done); in testGetPoolSize()
416 await(threadStarted); in testGetPoolSize()
[all …]
|
| D | ThreadPoolExecutorSubclassTest.java | 145 cond.await(); in get()
269 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS)); in testExecute()
290 await(done); in testGetActiveCount()
292 await(threadStarted); in testGetActiveCount()
363 threadProceed.await(); in testGetCompletedTaskCount()
366 await(threadStarted); in testGetCompletedTaskCount()
369 threadDone.await(); in testGetCompletedTaskCount()
517 await(done); in testGetLargestPoolSize()
520 await(threadsStarted); in testGetLargestPoolSize()
561 await(done); in testGetPoolSize()
[all …]
|
| D | ReentrantReadWriteLockTest.java | 183 enum AwaitMethod { await, awaitTimed, awaitNanos, awaitUntil } enumConstant
188 void await(Condition c, AwaitMethod awaitMethod) in await() method in ReentrantReadWriteLockTest
192 case await: in await()
193 c.await(); in await()
196 assertTrue(c.await(timeoutMillis, MILLISECONDS)); in await()
911 await(c, awaitMethod); in testAwait_IMSE()
981 assertFalse(c.await(timeoutMillis, MILLISECONDS));
1020 c.await(); in testAwait()
1024 await(locked); in testAwait()
1065 await(pleaseInterrupt); in testAwaitUninterruptibly()
[all …]
|
| D | DoubleAdderTest.java | 167 barrier.await(); in testAddAndSumMT()
168 barrier.await(); in testAddAndSumMT()
188 barrier.await(); in run()
193 barrier.await(); in run()
|
| D | LinkedBlockingDequeTest.java | 634 await(pleaseInterrupt); in testBlockingPut()
665 await(pleaseTake); in testPutWithTake()
669 await(pleaseInterrupt); in testPutWithTake()
696 await(pleaseInterrupt); in testTimedOffer()
739 await(pleaseInterrupt); in testBlockingTake()
805 aboutToWait.await(); in testInterruptedTimedPoll()
864 await(pleaseInterrupt); in testBlockingPutFirst()
895 await(pleaseTake); in testPutFirstWithTake()
899 await(pleaseInterrupt); in testPutFirstWithTake()
926 await(pleaseInterrupt); in testTimedOfferFirst()
[all …]
|
| /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 | 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 | 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 | 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 | 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 | DoubleAdderTest.java | 144 barrier.await(); in testAddAndSumMT()
145 barrier.await(); in testAddAndSumMT()
165 barrier.await(); in run()
170 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 | LongAdderTest.java | 167 barrier.await(); in testAddAndSumMT()
168 barrier.await(); in testAddAndSumMT()
188 barrier.await(); in run()
193 barrier.await(); in run()
|
| /libcore/ojluni/src/test/java/util/Vector/ |
| D | SerializationDeadlock.java | 70 testStart.await(); in main()
76 testEnd.await(); in main()
93 await(); in writeObject()
123 testEnd.await(); in run()
|
| /libcore/ojluni/src/main/java/java/util/concurrent/locks/ |
| D | Condition.java | 232 void await() throws InterruptedException; in await() method
376 boolean await(long time, TimeUnit unit) throws InterruptedException; in await() method
|