Home
last modified time | relevance | path

Searched refs:await (Results 1 – 25 of 77) sorted by relevance

1234

/libcore/ojluni/src/test/java/util/concurrent/tck/
DCyclicBarrierTest.java105 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 …]
DCountDownLatchTest.java95 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 …]
DReentrantLockTest.java174 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 …]
DScheduledExecutorTest.java81 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS)); in testExecute()
102 assertTrue(done.await(0L, MILLISECONDS)); in testSchedule1()
120 await(done); in testSchedule3()
142 await(done); in testSchedule4()
164 await(done); in testSchedule5()
192 await(done, totalDelayMillis + LONG_DELAY_MS); in testFixedRateSequence()
238 await(done, totalDelayMillis + cycles * LONG_DELAY_MS); in testFixedDelaySequence()
371 await(done); in testGetActiveCount()
373 await(threadStarted); in testGetActiveCount()
393 threadProceed.await(); in testGetCompletedTaskCount()
[all …]
DExchangerTest.java107 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()
DDoubleAdderTest.java167 barrier.await(); in testAddAndSumMT()
168 barrier.await(); in testAddAndSumMT()
188 barrier.await(); in run()
193 barrier.await(); in run()
DLongAdderTest.java190 barrier.await(); in testAddAndSumMT()
191 barrier.await(); in testAddAndSumMT()
211 barrier.await(); in run()
216 barrier.await(); in run()
DLinkedBlockingDequeTest.java634 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 …]
DBlockingQueueTest.java249 barrier.await(); in testTimedPollWithOffer()
260 barrier.await(); in testTimedPollWithOffer()
270 barrier.await(); in testTimedPollWithOffer()
275 barrier.await(); in testTimedPollWithOffer()
297 await(threadStarted);
338 await(threadStarted);
/libcore/jsr166-tests/src/test/java/jsr166/
DCyclicBarrierTest.java86 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 …]
DCountDownLatchTest.java72 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 …]
DReentrantLockTest.java151 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 …]
DScheduledExecutorTest.java59 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 …]
DExchangerTest.java84 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()
DScheduledExecutorSubclassTest.java116 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 …]
DThreadPoolExecutorTest.java100 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 …]
DDoubleAdderTest.java144 barrier.await(); in testAddAndSumMT()
145 barrier.await(); in testAddAndSumMT()
165 barrier.await(); in run()
170 barrier.await(); in run()
DLongAdderTest.java167 barrier.await(); in testAddAndSumMT()
168 barrier.await(); in testAddAndSumMT()
188 barrier.await(); in run()
193 barrier.await(); in run()
DReentrantReadWriteLockTest.java160 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 …]
DLinkedBlockingDequeTest.java600 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 …]
DBlockingQueueTest.java225 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);
/libcore/ojluni/src/main/java/java/util/concurrent/locks/
DCondition.java232 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/
DCountDownLatch.java231 public void await() throws InterruptedException { in await() method in CountDownLatch
276 public boolean await(long timeout, TimeUnit unit) in await() method in CountDownLatch
DCyclicBarrier.java235 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/lang/
DThreadGroupTest.java54 assertTrue("Some thread was not interrupted", mLatch.await(5, TimeUnit.SECONDS)); in interrupt_shouldInterruptAllThreadsInAGroup()
70 assertTrue("Some thread was not interrupted", mLatch.await(5, TimeUnit.SECONDS)); in interrupt_shouldInterruptThreadsInSubgroups()
86 assertFalse("Both threads were interrupted", mLatch.await(5, TimeUnit.SECONDS)); in interrupt_shouldNotInterruptThreadsInParentGroup()

1234