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.java105 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testAwait_Interruptible() local
115 pleaseInterrupt.countDown(); in testAwait_Interruptible()
125 await(pleaseInterrupt); in testAwait_Interruptible()
136 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedAwait_Interruptible() local
146 pleaseInterrupt.countDown(); in testTimedAwait_Interruptible()
156 await(pleaseInterrupt); in testTimedAwait_Interruptible()
DLinkedBlockingDequeTest.java550 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut() local
565 pleaseInterrupt.countDown(); in testBlockingPut()
573 await(pleaseInterrupt); in testBlockingPut()
588 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake() local
596 pleaseInterrupt.countDown(); in testPutWithTake()
608 await(pleaseInterrupt); in testPutWithTake()
620 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer() local
628 pleaseInterrupt.countDown(); in testTimedOffer()
635 await(pleaseInterrupt); in testTimedOffer()
656 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
[all …]
DLockSupportTest.java171 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testParkBeforeInterrupt() local
174 pleaseInterrupt.countDown(); in testParkBeforeInterrupt()
181 await(pleaseInterrupt); in testParkBeforeInterrupt()
209 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testParkAfterInterrupt() local
213 pleaseInterrupt.countDown(); in testParkAfterInterrupt()
221 await(pleaseInterrupt); in testParkAfterInterrupt()
DSynchronousQueueTest.java101 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut() local
111 pleaseInterrupt.countDown(); in testBlockingPut()
119 await(pleaseInterrupt); in testBlockingPut()
134 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake() local
140 pleaseInterrupt.countDown(); in testPutWithTake()
153 await(pleaseInterrupt); in testPutWithTake()
167 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer() local
173 pleaseInterrupt.countDown(); in testTimedOffer()
180 await(pleaseInterrupt); in testTimedOffer()
229 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedPollWithOffer() local
[all …]
DCyclicBarrierTest.java120 final CountDownLatch pleaseInterrupt = new CountDownLatch(2); in testAwait1_Interrupted_BrokenBarrier() local
123 pleaseInterrupt.countDown(); in testAwait1_Interrupted_BrokenBarrier()
128 pleaseInterrupt.countDown(); in testAwait1_Interrupted_BrokenBarrier()
134 await(pleaseInterrupt); in testAwait1_Interrupted_BrokenBarrier()
146 final CountDownLatch pleaseInterrupt = new CountDownLatch(2); in testAwait2_Interrupted_BrokenBarrier() local
149 pleaseInterrupt.countDown(); in testAwait2_Interrupted_BrokenBarrier()
154 pleaseInterrupt.countDown(); in testAwait2_Interrupted_BrokenBarrier()
160 await(pleaseInterrupt); in testAwait2_Interrupted_BrokenBarrier()
DTimeUnitTest.java354 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedWait_Interruptible() local
369 pleaseInterrupt.countDown(); in testTimedWait_Interruptible()
379 await(pleaseInterrupt); in testTimedWait_Interruptible()
389 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedJoin_Interruptible() local
404 pleaseInterrupt.countDown(); in testTimedJoin_Interruptible()
412 await(pleaseInterrupt); in testTimedJoin_Interruptible()
424 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedSleep_Interruptible() local
435 pleaseInterrupt.countDown(); in testTimedSleep_Interruptible()
443 await(pleaseInterrupt); in testTimedSleep_Interruptible()
DLinkedBlockingQueueTest.java240 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut() local
255 pleaseInterrupt.countDown(); in testBlockingPut()
263 await(pleaseInterrupt); in testBlockingPut()
278 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake() local
286 pleaseInterrupt.countDown(); in testPutWithTake()
298 await(pleaseInterrupt); in testPutWithTake()
310 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer() local
318 pleaseInterrupt.countDown(); in testTimedOffer()
325 await(pleaseInterrupt); in testTimedOffer()
346 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
[all …]
DArrayBlockingQueueTest.java250 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut() local
265 pleaseInterrupt.countDown(); in testBlockingPut()
273 await(pleaseInterrupt); in testBlockingPut()
288 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake() local
296 pleaseInterrupt.countDown(); in testPutWithTake()
308 await(pleaseInterrupt); in testPutWithTake()
320 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer() local
328 pleaseInterrupt.countDown(); in testTimedOffer()
335 await(pleaseInterrupt); in testTimedOffer()
356 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
[all …]
DPhaserTest.java451 final CountDownLatch pleaseInterrupt = new CountDownLatch(2);
462 pleaseInterrupt.countDown();
479 pleaseInterrupt.countDown();
487 await(pleaseInterrupt);
563 final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
569 pleaseInterrupt.countDown();
575 await(pleaseInterrupt);
589 final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
595 pleaseInterrupt.countDown();
600 await(pleaseInterrupt);
DSemaphoreTest.java222 final Semaphore pleaseInterrupt = new Semaphore(0, fair); in testInterruptible() local
245 pleaseInterrupt.release(); in testInterruptible()
256 await(pleaseInterrupt); in testInterruptible()
272 final Semaphore pleaseInterrupt = new Semaphore(-1, fair); in testUninterruptible() local
277 pleaseInterrupt.release(); in testUninterruptible()
286 pleaseInterrupt.release(); in testUninterruptible()
291 await(pleaseInterrupt); in testUninterruptible()
DFutureTaskTest.java707 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testGet_interruptible() local
718 pleaseInterrupt.countDown(); in testGet_interruptible()
726 await(pleaseInterrupt); in testGet_interruptible()
736 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedGet_interruptible() local
747 pleaseInterrupt.countDown(); in testTimedGet_interruptible()
755 await(pleaseInterrupt); in testTimedGet_interruptible()
DDelayQueueTest.java336 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
350 pleaseInterrupt.countDown(); in testBlockingTake()
358 await(pleaseInterrupt); in testBlockingTake()
407 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testInterruptedTimedPoll() local
422 pleaseInterrupt.countDown(); in testInterruptedTimedPoll()
430 await(pleaseInterrupt); in testInterruptedTimedPoll()
DReentrantLockTest.java886 final CountDownLatch pleaseInterrupt = new CountDownLatch(2); in testAwaitUninterruptibly() local
892 pleaseInterrupt.countDown(); in testAwaitUninterruptibly()
903 pleaseInterrupt.countDown(); in testAwaitUninterruptibly()
909 await(pleaseInterrupt); in testAwaitUninterruptibly()
940 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testInterruptible() local
946 pleaseInterrupt.countDown(); in testInterruptible()
957 await(pleaseInterrupt); in testInterruptible()
DLinkedTransferQueueTest.java192 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
206 pleaseInterrupt.countDown(); in testBlockingTake()
214 await(pleaseInterrupt); in testBlockingTake()
910 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTryTransfer5() local
922 pleaseInterrupt.countDown(); in testTryTransfer5()
930 await(pleaseInterrupt); in testTryTransfer5()
DAbstractQueuedLongSynchronizerTest.java948 final BooleanLatch pleaseInterrupt = new BooleanLatch();
952 assertTrue(pleaseInterrupt.releaseShared(0));
959 pleaseInterrupt.acquireShared(0);
986 final BooleanLatch pleaseInterrupt = new BooleanLatch();
990 assertTrue(pleaseInterrupt.releaseShared(0));
994 pleaseInterrupt.acquireShared(0);
DAbstractQueuedSynchronizerTest.java951 final BooleanLatch pleaseInterrupt = new BooleanLatch();
955 assertTrue(pleaseInterrupt.releaseShared(0));
962 pleaseInterrupt.acquireShared(0);
989 final BooleanLatch pleaseInterrupt = new BooleanLatch();
993 assertTrue(pleaseInterrupt.releaseShared(0));
997 pleaseInterrupt.acquireShared(0);
DPriorityBlockingQueueTest.java302 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake() local
316 pleaseInterrupt.countDown(); in testBlockingTake()
324 await(pleaseInterrupt); in testBlockingTake()
DReentrantReadWriteLockTest.java1011 final CountDownLatch pleaseInterrupt = new CountDownLatch(2); in testAwaitUninterruptibly() local
1017 pleaseInterrupt.countDown(); in testAwaitUninterruptibly()
1028 pleaseInterrupt.countDown(); in testAwaitUninterruptibly()
1034 await(pleaseInterrupt); in testAwaitUninterruptibly()