Home
last modified time | relevance | path

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

12

/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 …]
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 …]
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);
/libcore/ojluni/src/test/java/util/concurrent/tck/
DCountDownLatchTest.java139 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testAwait_Interruptible() local
149 pleaseInterrupt.countDown(); in testAwait_Interruptible()
159 await(pleaseInterrupt); in testAwait_Interruptible()
170 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedAwait_Interruptible() local
180 pleaseInterrupt.countDown(); in testTimedAwait_Interruptible()
190 await(pleaseInterrupt); in testTimedAwait_Interruptible()
DLinkedBlockingDequeTest.java611 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut() local
626 pleaseInterrupt.countDown(); in testBlockingPut()
634 await(pleaseInterrupt); in testBlockingPut()
649 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake() local
657 pleaseInterrupt.countDown(); in testPutWithTake()
669 await(pleaseInterrupt); in testPutWithTake()
681 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer() local
689 pleaseInterrupt.countDown(); in testTimedOffer()
696 await(pleaseInterrupt); in testTimedOffer()
717 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
[all …]
DCyclicBarrierTest.java152 final CountDownLatch pleaseInterrupt = new CountDownLatch(2); in testAwait1_Interrupted_BrokenBarrier() local
155 pleaseInterrupt.countDown(); in testAwait1_Interrupted_BrokenBarrier()
160 pleaseInterrupt.countDown(); in testAwait1_Interrupted_BrokenBarrier()
166 await(pleaseInterrupt); in testAwait1_Interrupted_BrokenBarrier()
178 final CountDownLatch pleaseInterrupt = new CountDownLatch(2); in testAwait2_Interrupted_BrokenBarrier() local
181 pleaseInterrupt.countDown(); in testAwait2_Interrupted_BrokenBarrier()
186 pleaseInterrupt.countDown(); in testAwait2_Interrupted_BrokenBarrier()
192 await(pleaseInterrupt); in testAwait2_Interrupted_BrokenBarrier()
DLockSupportTest.java213 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testParkBeforeInterrupt() local
216 pleaseInterrupt.countDown(); in testParkBeforeInterrupt()
223 await(pleaseInterrupt); in testParkBeforeInterrupt()
251 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testParkAfterInterrupt() local
255 pleaseInterrupt.countDown(); in testParkAfterInterrupt()
263 await(pleaseInterrupt); in testParkAfterInterrupt()
DLinkedBlockingQueueTest.java299 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut() local
314 pleaseInterrupt.countDown(); in testBlockingPut()
322 await(pleaseInterrupt); in testBlockingPut()
337 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake() local
345 pleaseInterrupt.countDown(); in testPutWithTake()
357 await(pleaseInterrupt); in testPutWithTake()
369 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer() local
377 pleaseInterrupt.countDown(); in testTimedOffer()
384 await(pleaseInterrupt); in testTimedOffer()
405 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
[all …]
DTimeUnitTest.java531 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedWait_Interruptible() local
546 pleaseInterrupt.countDown(); in testTimedWait_Interruptible()
556 await(pleaseInterrupt); in testTimedWait_Interruptible()
566 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedJoin_Interruptible() local
581 pleaseInterrupt.countDown(); in testTimedJoin_Interruptible()
589 await(pleaseInterrupt); in testTimedJoin_Interruptible()
601 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedSleep_Interruptible() local
612 pleaseInterrupt.countDown(); in testTimedSleep_Interruptible()
620 await(pleaseInterrupt); in testTimedSleep_Interruptible()
DArrayBlockingQueueTest.java347 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut() local
362 pleaseInterrupt.countDown(); in testBlockingPut()
370 await(pleaseInterrupt); in testBlockingPut()
385 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake() local
393 pleaseInterrupt.countDown(); in testPutWithTake()
405 await(pleaseInterrupt); in testPutWithTake()
417 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer() local
425 pleaseInterrupt.countDown(); in testTimedOffer()
432 await(pleaseInterrupt); in testTimedOffer()
453 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
[all …]
DSemaphoreTest.java258 final Semaphore pleaseInterrupt = new Semaphore(0, fair); in testInterruptible() local
281 pleaseInterrupt.release(); in testInterruptible()
292 await(pleaseInterrupt); in testInterruptible()
308 final Semaphore pleaseInterrupt = new Semaphore(-1, fair); in testUninterruptible() local
313 pleaseInterrupt.release(); in testUninterruptible()
322 pleaseInterrupt.release(); in testUninterruptible()
327 await(pleaseInterrupt); in testUninterruptible()
DPhaserTest.java486 final CountDownLatch pleaseInterrupt = new CountDownLatch(2);
497 pleaseInterrupt.countDown();
514 pleaseInterrupt.countDown();
522 await(pleaseInterrupt);
624 final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
630 pleaseInterrupt.countDown();
635 await(pleaseInterrupt);
DDelayQueueTest.java366 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
380 pleaseInterrupt.countDown(); in testBlockingTake()
388 await(pleaseInterrupt); in testBlockingTake()
437 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testInterruptedTimedPoll() local
454 pleaseInterrupt.countDown(); in testInterruptedTimedPoll()
463 await(pleaseInterrupt); in testInterruptedTimedPoll()
DReentrantLockTest.java917 final CountDownLatch pleaseInterrupt = new CountDownLatch(2); in testAwaitUninterruptibly() local
923 pleaseInterrupt.countDown(); in testAwaitUninterruptibly()
934 pleaseInterrupt.countDown(); in testAwaitUninterruptibly()
940 await(pleaseInterrupt); in testAwaitUninterruptibly()
971 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testInterruptible() local
977 pleaseInterrupt.countDown(); in testInterruptible()
988 await(pleaseInterrupt); in testInterruptible()
DLinkedTransferQueueTest.java237 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
251 pleaseInterrupt.countDown(); in testBlockingTake()
259 await(pleaseInterrupt); in testBlockingTake()
971 final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
984 pleaseInterrupt.countDown();
993 await(pleaseInterrupt);
DAbstractQueuedLongSynchronizerTest.java1002 final BooleanLatch pleaseInterrupt = new BooleanLatch();
1006 assertTrue(pleaseInterrupt.releaseShared(0));
1013 pleaseInterrupt.acquireShared(0);
1040 final BooleanLatch pleaseInterrupt = new BooleanLatch();
1044 assertTrue(pleaseInterrupt.releaseShared(0));
1048 pleaseInterrupt.acquireShared(0);

12