Home
last modified time | relevance | path

Searched refs:pleaseInterrupt (Results 1 – 18 of 18) sorted by relevance

/libcore/jsr166-tests/src/test/java/jsr166/
DCountDownLatchTest.java116 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testAwait_Interruptible() local
126 pleaseInterrupt.countDown(); in testAwait_Interruptible()
136 await(pleaseInterrupt); in testAwait_Interruptible()
147 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedAwait_Interruptible() local
157 pleaseInterrupt.countDown(); in testTimedAwait_Interruptible()
167 await(pleaseInterrupt); in testTimedAwait_Interruptible()
DLinkedBlockingDequeTest.java577 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut() local
592 pleaseInterrupt.countDown(); in testBlockingPut()
600 await(pleaseInterrupt); in testBlockingPut()
615 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake() local
623 pleaseInterrupt.countDown(); in testPutWithTake()
635 await(pleaseInterrupt); in testPutWithTake()
647 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer() local
655 pleaseInterrupt.countDown(); in testTimedOffer()
662 await(pleaseInterrupt); in testTimedOffer()
683 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
[all …]
DSynchronousQueueTest.java129 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut() local
139 pleaseInterrupt.countDown(); in testBlockingPut()
147 await(pleaseInterrupt); in testBlockingPut()
162 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake() local
168 pleaseInterrupt.countDown(); in testPutWithTake()
181 await(pleaseInterrupt); in testPutWithTake()
195 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer() local
201 pleaseInterrupt.countDown(); in testTimedOffer()
208 await(pleaseInterrupt); in testTimedOffer()
257 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedPollWithOffer() local
[all …]
DTimeUnitTest.java337 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedWait_Interruptible() local
352 pleaseInterrupt.countDown(); in testTimedWait_Interruptible()
362 await(pleaseInterrupt); in testTimedWait_Interruptible()
372 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedJoin_Interruptible() local
387 pleaseInterrupt.countDown(); in testTimedJoin_Interruptible()
395 await(pleaseInterrupt); in testTimedJoin_Interruptible()
407 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedSleep_Interruptible() local
418 pleaseInterrupt.countDown(); in testTimedSleep_Interruptible()
426 await(pleaseInterrupt); in testTimedSleep_Interruptible()
DCyclicBarrierTest.java131 final CountDownLatch pleaseInterrupt = new CountDownLatch(2); in testAwait1_Interrupted_BrokenBarrier() local
134 pleaseInterrupt.countDown(); in testAwait1_Interrupted_BrokenBarrier()
139 pleaseInterrupt.countDown(); in testAwait1_Interrupted_BrokenBarrier()
145 await(pleaseInterrupt); in testAwait1_Interrupted_BrokenBarrier()
157 final CountDownLatch pleaseInterrupt = new CountDownLatch(2); in testAwait2_Interrupted_BrokenBarrier() local
160 pleaseInterrupt.countDown(); in testAwait2_Interrupted_BrokenBarrier()
165 pleaseInterrupt.countDown(); in testAwait2_Interrupted_BrokenBarrier()
171 await(pleaseInterrupt); in testAwait2_Interrupted_BrokenBarrier()
DLockSupportTest.java189 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testParkBeforeInterrupt() local
192 pleaseInterrupt.countDown(); in testParkBeforeInterrupt()
199 await(pleaseInterrupt); in testParkBeforeInterrupt()
227 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testParkAfterInterrupt() local
231 pleaseInterrupt.countDown(); in testParkAfterInterrupt()
239 await(pleaseInterrupt); in testParkAfterInterrupt()
DLinkedBlockingQueueTest.java269 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut() local
284 pleaseInterrupt.countDown(); in testBlockingPut()
292 await(pleaseInterrupt); in testBlockingPut()
307 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake() local
315 pleaseInterrupt.countDown(); in testPutWithTake()
327 await(pleaseInterrupt); in testPutWithTake()
339 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer() local
347 pleaseInterrupt.countDown(); in testTimedOffer()
354 await(pleaseInterrupt); in testTimedOffer()
375 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
[all …]
DArrayBlockingQueueTest.java279 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut() local
294 pleaseInterrupt.countDown(); in testBlockingPut()
302 await(pleaseInterrupt); in testBlockingPut()
317 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake() local
325 pleaseInterrupt.countDown(); in testPutWithTake()
337 await(pleaseInterrupt); in testPutWithTake()
349 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer() local
357 pleaseInterrupt.countDown(); in testTimedOffer()
364 await(pleaseInterrupt); in testTimedOffer()
385 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
[all …]
DSemaphoreTest.java235 final Semaphore pleaseInterrupt = new Semaphore(0, fair); in testInterruptible() local
258 pleaseInterrupt.release(); in testInterruptible()
269 await(pleaseInterrupt); in testInterruptible()
285 final Semaphore pleaseInterrupt = new Semaphore(-1, fair); in testUninterruptible() local
290 pleaseInterrupt.release(); in testUninterruptible()
299 pleaseInterrupt.release(); in testUninterruptible()
304 await(pleaseInterrupt); in testUninterruptible()
DPhaserTest.java462 final CountDownLatch pleaseInterrupt = new CountDownLatch(2);
473 pleaseInterrupt.countDown();
490 pleaseInterrupt.countDown();
498 await(pleaseInterrupt);
600 final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
606 pleaseInterrupt.countDown();
611 await(pleaseInterrupt);
DDelayQueueTest.java358 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
372 pleaseInterrupt.countDown(); in testBlockingTake()
380 await(pleaseInterrupt); in testBlockingTake()
429 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testInterruptedTimedPoll() local
446 pleaseInterrupt.countDown(); in testInterruptedTimedPoll()
455 await(pleaseInterrupt); in testInterruptedTimedPoll()
DFutureTaskTest.java725 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testGet_interruptible() local
736 pleaseInterrupt.countDown(); in testGet_interruptible()
744 await(pleaseInterrupt); in testGet_interruptible()
754 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedGet_interruptible() local
765 pleaseInterrupt.countDown(); in testTimedGet_interruptible()
773 await(pleaseInterrupt); in testTimedGet_interruptible()
DReentrantLockTest.java894 final CountDownLatch pleaseInterrupt = new CountDownLatch(2); in testAwaitUninterruptibly() local
900 pleaseInterrupt.countDown(); in testAwaitUninterruptibly()
911 pleaseInterrupt.countDown(); in testAwaitUninterruptibly()
917 await(pleaseInterrupt); in testAwaitUninterruptibly()
948 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testInterruptible() local
954 pleaseInterrupt.countDown(); in testInterruptible()
965 await(pleaseInterrupt); in testInterruptible()
DLinkedTransferQueueTest.java219 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
233 pleaseInterrupt.countDown(); in testBlockingTake()
241 await(pleaseInterrupt); in testBlockingTake()
957 final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
970 pleaseInterrupt.countDown();
979 await(pleaseInterrupt);
DAbstractQueuedLongSynchronizerTest.java974 final BooleanLatch pleaseInterrupt = new BooleanLatch();
978 assertTrue(pleaseInterrupt.releaseShared(0));
985 pleaseInterrupt.acquireShared(0);
1012 final BooleanLatch pleaseInterrupt = new BooleanLatch();
1016 assertTrue(pleaseInterrupt.releaseShared(0));
1020 pleaseInterrupt.acquireShared(0);
DAbstractQueuedSynchronizerTest.java977 final BooleanLatch pleaseInterrupt = new BooleanLatch();
981 assertTrue(pleaseInterrupt.releaseShared(0));
988 pleaseInterrupt.acquireShared(0);
1015 final BooleanLatch pleaseInterrupt = new BooleanLatch();
1019 assertTrue(pleaseInterrupt.releaseShared(0));
1023 pleaseInterrupt.acquireShared(0);
DPriorityBlockingQueueTest.java328 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
342 pleaseInterrupt.countDown(); in testBlockingTake()
350 await(pleaseInterrupt); in testBlockingTake()
DReentrantReadWriteLockTest.java1022 final CountDownLatch pleaseInterrupt = new CountDownLatch(2); in testAwaitUninterruptibly() local
1028 pleaseInterrupt.countDown(); in testAwaitUninterruptibly()
1039 pleaseInterrupt.countDown(); in testAwaitUninterruptibly()
1045 await(pleaseInterrupt); in testAwaitUninterruptibly()