Home
last modified time | relevance | path

Searched refs:CheckedRunnable (Results 1 – 25 of 42) sorted by relevance

12

/libcore/jsr166-tests/src/test/java/jsr166/
DExchangerTest.java25 Thread t1 = newStartedThread(new CheckedRunnable() { in testExchange()
30 Thread t2 = newStartedThread(new CheckedRunnable() { in testExchange()
45 Thread t1 = newStartedThread(new CheckedRunnable() { in testTimedExchange()
50 Thread t2 = newStartedThread(new CheckedRunnable() { in testTimedExchange()
99 Thread t = newStartedThread(new CheckedRunnable() { in testExchange_TimeoutException()
125 Thread t2 = newStartedThread(new CheckedRunnable() { in testReplacementAfterExchange()
132 Thread t3 = newStartedThread(new CheckedRunnable() { in testReplacementAfterExchange()
DCyclicBarrierTest.java99 Thread t = newStartedThread(new CheckedRunnable() { in testTwoParties()
171 Thread t = newStartedThread(new CheckedRunnable() { in testAwait3_TimeoutException()
190 Thread t1 = newStartedThread(new CheckedRunnable() { in testAwait4_Timeout_BrokenBarrier()
197 Thread t2 = newStartedThread(new CheckedRunnable() { in testAwait4_Timeout_BrokenBarrier()
218 Thread t1 = newStartedThread(new CheckedRunnable() { in testAwait5_Timeout_BrokenBarrier()
225 Thread t2 = newStartedThread(new CheckedRunnable() { in testAwait5_Timeout_BrokenBarrier()
276 Thread t1 = newStartedThread(new CheckedRunnable() { in testReset_NoBrokenBarrier()
280 Thread t2 = newStartedThread(new CheckedRunnable() { in testReset_NoBrokenBarrier()
296 Thread t = newStartedThread(new CheckedRunnable() { in testReset_Leakage()
326 Thread t1 = newStartedThread(new CheckedRunnable() { in testResetWithoutBreakage()
[all …]
DLockSupportTest.java100 Thread t = newStartedThread(new CheckedRunnable() { in testParkBeforeUnpark()
135 Thread t = newStartedThread(new CheckedRunnable() { in testParkAfterUnpark()
172 Thread t = newStartedThread(new CheckedRunnable() { in testParkBeforeInterrupt()
211 Thread t = newStartedThread(new CheckedRunnable() { in testParkAfterInterrupt()
243 Thread t = newStartedThread(new CheckedRunnable() { in testParkTimesOut()
281 Thread t = newStartedThread(new CheckedRunnable() { in testGetBlocker()
331 Thread t = newStartedThread(new CheckedRunnable() { in testPark0()
355 Thread t = newStartedThread(new CheckedRunnable() { in testParkNeg()
DCountDownLatchTest.java57 Thread t = newStartedThread(new CheckedRunnable() { in testAwait()
82 Thread t = newStartedThread(new CheckedRunnable() { in testTimedAwait()
106 Thread t = newStartedThread(new CheckedRunnable() { in testAwait_Interruptible()
137 Thread t = newStartedThread(new CheckedRunnable() { in testTimedAwait_Interruptible()
167 Thread t = newStartedThread(new CheckedRunnable() { in testAwaitTimeout()
DExecutorsTest.java177 final Runnable task = new CheckedRunnable() { in testNewSingleThreadScheduledExecutor()
203 final Runnable task = new CheckedRunnable() { in testNewScheduledThreadPool()
231 final Runnable task = new CheckedRunnable() { in testUnconfigurableScheduledExecutorService()
268 threads.add(newStartedThread(new CheckedRunnable() { in testTimedCallable()
288 Runnable r = new CheckedRunnable() { in testDefaultThreadFactory()
327 Runnable r = new CheckedRunnable() { in testPrivilegedThreadFactory()
332 Runnable r = new CheckedRunnable() { in testPrivilegedThreadFactory()
395 Runnable r = new CheckedRunnable() { in testCreatePrivilegedCallableUsingCCLWithNoPrivs()
413 Runnable r = new CheckedRunnable() { in testPrivilegedCallableUsingCCLWithPrivs()
432 Runnable r = new CheckedRunnable() { in testPrivilegedCallableWithNoPrivs()
[all …]
DReentrantReadWriteLockTest.java25 class InterruptibleLockRunnable extends CheckedRunnable {
396 Thread t = newStartedThread(new CheckedRunnable() { in testWriteTryLockWhenLocked()
414 Thread t = newStartedThread(new CheckedRunnable() { in testReadTryLockWhenLocked()
431 Thread t = newStartedThread(new CheckedRunnable() { in testMultipleReadLocks()
454 Thread t = newStartedThread(new CheckedRunnable() { in testWriteAfterReadLock()
480 Thread t1 = newStartedThread(new CheckedRunnable() { in testWriteAfterMultipleReadLocks()
488 Thread t2 = newStartedThread(new CheckedRunnable() { in testWriteAfterMultipleReadLocks()
515 Thread t1 = newStartedThread(new CheckedRunnable() { in testReaderWriterReaderFairFifo()
525 Thread t2 = newStartedThread(new CheckedRunnable() { in testReaderWriterReaderFairFifo()
552 Thread t1 = newStartedThread(new CheckedRunnable() { in testReadAfterWriteLock()
[all …]
DSynchronousQueueTest.java102 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingPut()
135 Thread t = newStartedThread(new CheckedRunnable() { in testPutWithTake()
168 Thread t = newStartedThread(new CheckedRunnable() { in testTimedOffer()
230 Thread t = newStartedThread(new CheckedRunnable() { in testTimedPollWithOffer()
460 executor.execute(new CheckedRunnable() {
468 executor.execute(new CheckedRunnable() {
486 executor.execute(new CheckedRunnable() {
494 executor.execute(new CheckedRunnable() {
544 Thread t = newStartedThread(new CheckedRunnable() {
567 Thread t1 = newStartedThread(new CheckedRunnable() {
[all …]
DLinkedTransferQueueTest.java193 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingTake()
267 Thread t = newStartedThread(new CheckedRunnable() { in testInterruptedTimedPoll()
297 Thread t = newStartedThread(new CheckedRunnable() { in testTimedPollAfterInterrupt()
571 executor.execute(new CheckedRunnable() { in testOfferInExecutor()
577 executor.execute(new CheckedRunnable() { in testOfferInExecutor()
595 executor.execute(new CheckedRunnable() { in testPollInExecutor()
603 executor.execute(new CheckedRunnable() { in testPollInExecutor()
661 Thread t = newStartedThread(new CheckedRunnable() { in testDrainToWithActivePut()
705 Thread t = newStartedThread(new CheckedRunnable() { in testWaitingConsumer()
745 Thread t = newStartedThread(new CheckedRunnable() { in testTransfer2()
[all …]
DLinkedBlockingDequeTest.java551 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingPut()
589 Thread t = newStartedThread(new CheckedRunnable() { in testPutWithTake()
621 Thread t = newStartedThread(new CheckedRunnable() { in testTimedOffer()
657 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingTake()
729 Thread t = newStartedThread(new CheckedRunnable() { in testInterruptedTimedPoll()
783 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingPutFirst()
821 Thread t = newStartedThread(new CheckedRunnable() { in testPutFirstWithTake()
853 Thread t = newStartedThread(new CheckedRunnable() { in testTimedOfferFirst()
889 Thread t = newStartedThread(new CheckedRunnable() { in testTakeFirstFromEmptyBlocksInterruptibly()
911 Thread t = newStartedThread(new CheckedRunnable() { in testTakeFirstFromEmptyAfterInterrupt()
[all …]
DPhaserTest.java301 threads.add(newStartedThread(new CheckedRunnable() { in testArrive2()
414 Thread t = newStartedThread(new CheckedRunnable() {
453 Thread t1 = newStartedThread(new CheckedRunnable() {
470 Thread t2 = newStartedThread(new CheckedRunnable() {
507 Thread t = newStartedThread(new CheckedRunnable() {
536 Thread t = newStartedThread(new CheckedRunnable() {
565 Thread t = newStartedThread(new CheckedRunnable() {
591 Thread t = newStartedThread(new CheckedRunnable() {
618 threads.add(newStartedThread(new CheckedRunnable() {
644 threads.add(newStartedThread(new CheckedRunnable() {
[all …]
DBlockingQueueTest.java207 Thread t = newStartedThread(new CheckedRunnable() { in testTimedPollWithOffer()
249 Thread t = newStartedThread(new CheckedRunnable() {
271 Thread t = newStartedThread(new CheckedRunnable() {
290 Thread t = newStartedThread(new CheckedRunnable() {
312 Thread t = newStartedThread(new CheckedRunnable() {
DAbstractQueuedLongSynchronizerTest.java95 class InterruptibleSyncRunnable extends CheckedRunnable {
470 Thread t2 = newStartedThread(new CheckedRunnable() { in testGetSharedQueuedThreads_Shared()
506 Thread t = newStartedThread(new CheckedRunnable() { in testTryAcquireWhenSynced()
521 Thread t = newStartedThread(new CheckedRunnable() { in testAcquireNanos_Timeout()
545 Thread t = newStartedThread(new CheckedRunnable() { in testGetState()
658 Thread t = newStartedThread(new CheckedRunnable() {
798 Thread t = newStartedThread(new CheckedRunnable() {
831 final Thread t1 = newStartedThread(new CheckedRunnable() {
846 final Thread t2 = newStartedThread(new CheckedRunnable() {
879 final Thread t1 = new Thread(new CheckedRunnable() {
[all …]
DReentrantLockTest.java24 class InterruptibleLockRunnable extends CheckedRunnable {
373 Thread t = newStartedThread(new CheckedRunnable() { in testTryLockWhenLocked()
390 Thread t = newStartedThread(new CheckedRunnable() { in testTryLock_Timeout()
437 Thread t = newStartedThread(new CheckedRunnable() { in testIsLocked()
583 Thread t = newStartedThread(new CheckedRunnable() { in testAwait()
736 Thread t = newStartedThread(new CheckedRunnable() { in testHasWaiters()
770 Thread t1 = new Thread(new CheckedRunnable() { in testGetWaitQueueLength()
780 Thread t2 = new Thread(new CheckedRunnable() { in testGetWaitQueueLength()
828 Thread t1 = new Thread(new CheckedRunnable() { in testGetWaitingThreads()
837 Thread t2 = new Thread(new CheckedRunnable() { in testGetWaitingThreads()
[all …]
DAbstractQueuedSynchronizerTest.java99 class InterruptibleSyncRunnable extends CheckedRunnable {
473 Thread t2 = newStartedThread(new CheckedRunnable() { in testGetSharedQueuedThreads_Shared()
509 Thread t = newStartedThread(new CheckedRunnable() { in testTryAcquireWhenSynced()
524 Thread t = newStartedThread(new CheckedRunnable() { in testAcquireNanos_Timeout()
548 Thread t = newStartedThread(new CheckedRunnable() { in testGetState()
661 Thread t = newStartedThread(new CheckedRunnable() {
801 Thread t = newStartedThread(new CheckedRunnable() {
834 final Thread t1 = newStartedThread(new CheckedRunnable() {
849 final Thread t2 = newStartedThread(new CheckedRunnable() {
882 final Thread t1 = new Thread(new CheckedRunnable() {
[all …]
DJSR166TestCase.java671 public abstract class CheckedRunnable implements Runnable { class in JSR166TestCase
794 return new CheckedRunnable() {
843 public class ShortRunnable extends CheckedRunnable {
855 public class SmallRunnable extends CheckedRunnable {
861 public class SmallPossiblyInterruptedRunnable extends CheckedRunnable {
876 public class MediumRunnable extends CheckedRunnable {
889 return new CheckedRunnable() {
897 public class MediumPossiblyInterruptedRunnable extends CheckedRunnable {
905 public class LongPossiblyInterruptedRunnable extends CheckedRunnable {
DScheduledExecutorTest.java25 final Runnable task = new CheckedRunnable() { in testExecute()
68 Runnable task = new CheckedRunnable() { in testSchedule3()
90 Runnable task = new CheckedRunnable() { in testSchedule4()
114 Runnable task = new CheckedRunnable() { in testSchedule5()
287 p.execute(new CheckedRunnable() { in testGetActiveCount()
312 p.execute(new CheckedRunnable() { in testGetCompletedTaskCount()
355 p.execute(new CheckedRunnable() { in testGetLargestPoolSize()
380 p.execute(new CheckedRunnable() { in testGetPoolSize()
406 p.execute(new CheckedRunnable() { in testGetTaskCount()
478 p.execute(new CheckedRunnable() { in testIsTerminated()
[all …]
DLinkedBlockingQueueTest.java241 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingPut()
279 Thread t = newStartedThread(new CheckedRunnable() { in testPutWithTake()
311 Thread t = newStartedThread(new CheckedRunnable() { in testTimedOffer()
347 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingTake()
419 Thread t = newStartedThread(new CheckedRunnable() { in testInterruptedTimedPoll()
690 executor.execute(new CheckedRunnable() { in testOfferInExecutor()
698 executor.execute(new CheckedRunnable() { in testOfferInExecutor()
714 executor.execute(new CheckedRunnable() { in testPollInExecutor()
722 executor.execute(new CheckedRunnable() { in testPollInExecutor()
778 Thread t = new Thread(new CheckedRunnable() { in testDrainToWithActivePut()
DScheduledExecutorSubclassTest.java77 final Runnable task = new CheckedRunnable() { in testExecute()
120 Runnable task = new CheckedRunnable() { in testSchedule3()
142 Runnable task = new CheckedRunnable() { in testSchedule4()
166 Runnable task = new CheckedRunnable() { in testSchedule5()
337 p.execute(new CheckedRunnable() { in testGetActiveCount()
362 p.execute(new CheckedRunnable() { in testGetCompletedTaskCount()
405 p.execute(new CheckedRunnable() { in testGetLargestPoolSize()
430 p.execute(new CheckedRunnable() { in testGetPoolSize()
456 p.execute(new CheckedRunnable() { in testGetTaskCount()
527 p.execute(new CheckedRunnable() { in testIsTerminated()
[all …]
DFutureTaskTest.java209 class Counter extends CheckedRunnable {
400 new PublicFutureTask(new CheckedRunnable() { in testCancelInterrupt()
431 new PublicFutureTask(new CheckedRunnable() { in testCancelInterrupt_ThrowsSecurityException()
537 Thread t1 = newStartedThread(new CheckedRunnable() { in testGetRun()
543 Thread t2 = newStartedThread(new CheckedRunnable() { in testGetRun()
576 Thread t1 = newStartedThread(new CheckedRunnable() { in testGetSet()
582 Thread t2 = newStartedThread(new CheckedRunnable() { in testGetSet()
709 Thread t = newStartedThread(new CheckedRunnable() { in testGet_interruptible()
738 Thread t = newStartedThread(new CheckedRunnable() { in testTimedGet_interruptible()
DThreadPoolExecutorTest.java65 final Runnable task = new CheckedRunnable() { in testExecute()
90 p.execute(new CheckedRunnable() { in testGetActiveCount()
152 p.execute(new CheckedRunnable() { in testGetCompletedTaskCount()
305 p.execute(new CheckedRunnable() { in testGetLargestPoolSize()
346 p.execute(new CheckedRunnable() { in testGetPoolSize()
372 p.execute(new CheckedRunnable() { in testGetTaskCount()
442 p.execute(new CheckedRunnable() { in testIsTerminated()
470 p.execute(new CheckedRunnable() { in testIsTerminating()
536 tasks[i] = new CheckedRunnable() { in testRemove()
1033 Runnable task = new CheckedRunnable() { in testSaturatedExecute()
[all …]
DArrayBlockingQueueTest.java251 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingPut()
289 Thread t = newStartedThread(new CheckedRunnable() { in testPutWithTake()
321 Thread t = newStartedThread(new CheckedRunnable() { in testTimedOffer()
357 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingTake()
430 Thread t = newStartedThread(new CheckedRunnable() { in testInterruptedTimedPoll()
756 executor.execute(new CheckedRunnable() { in testOfferInExecutor()
764 executor.execute(new CheckedRunnable() { in testOfferInExecutor()
781 executor.execute(new CheckedRunnable() { in testPollInExecutor()
789 executor.execute(new CheckedRunnable() { in testPollInExecutor()
845 Thread t = new Thread(new CheckedRunnable() { in testDrainToWithActivePut()
DPriorityBlockingQueueTest.java260 Thread t = newStartedThread(new CheckedRunnable() { in testPutWithTake()
276 Thread t = newStartedThread(new CheckedRunnable() { in testTimedOffer()
303 Thread t = newStartedThread(new CheckedRunnable() { in testBlockingTake()
375 Thread t = newStartedThread(new CheckedRunnable() { in testInterruptedTimedPoll()
603 executor.execute(new CheckedRunnable() { in testPollInExecutor()
611 executor.execute(new CheckedRunnable() { in testPollInExecutor()
665 Thread t = new Thread(new CheckedRunnable() { in testDrainToWithActivePut()
DSemaphoreTest.java39 class InterruptibleLockRunnable extends CheckedRunnable {
223 Thread t = newStartedThread(new CheckedRunnable() { in testInterruptible()
274 Thread t1 = newStartedThread(new CheckedRunnable() { in testUninterruptible()
283 Thread t2 = newStartedThread(new CheckedRunnable() { in testUninterruptible()
549 Thread t = newStartedThread(new CheckedRunnable() { in testReleaseAcquireDifferentThreads()
579 Thread t1 = newStartedThread(new CheckedRunnable() {
587 Thread t2 = newStartedThread(new CheckedRunnable() {
DAtomicMarkableReferenceTest.java93 Thread t = new Thread(new CheckedRunnable() { in testCompareAndSetInMultipleThreads()
113 Thread t = new Thread(new CheckedRunnable() { in testCompareAndSetInMultipleThreads2()
DAtomicStampedReferenceTest.java93 Thread t = new Thread(new CheckedRunnable() { in testCompareAndSetInMultipleThreads()
113 Thread t = new Thread(new CheckedRunnable() { in testCompareAndSetInMultipleThreads2()

12