/libcore/jsr166-tests/src/test/java/jsr166/ |
D | ScheduledExecutorTest.java | 31 assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); in testExecute() 143 delay(SMALL_DELAY_MS); in testFixedRateSequence() 148 assertTrue(c >= SMALL_DELAY_MS / SHORT_DELAY_MS); in testFixedRateSequence() 149 assertTrue(c <= SMALL_DELAY_MS + SHORT_DELAY_MS); in testFixedRateSequence() 161 delay(SMALL_DELAY_MS); in testFixedDelaySequence() 164 assertTrue(c >= SMALL_DELAY_MS / SHORT_DELAY_MS); in testFixedDelaySequence() 165 assertTrue(c <= SMALL_DELAY_MS + SHORT_DELAY_MS); in testFixedDelaySequence() 293 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetActiveCount() 361 assertTrue(threadsStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetLargestPoolSize() 386 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetPoolSize() [all …]
|
D | ScheduledExecutorSubclassTest.java | 83 assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); in testExecute() 195 delay(SMALL_DELAY_MS); in testFixedRateSequence() 200 assertTrue(c >= SMALL_DELAY_MS / SHORT_DELAY_MS); in testFixedRateSequence() 201 assertTrue(c <= SMALL_DELAY_MS + SHORT_DELAY_MS); in testFixedRateSequence() 213 delay(SMALL_DELAY_MS); in testFixedDelaySequence() 216 assertTrue(c >= SMALL_DELAY_MS / SHORT_DELAY_MS); in testFixedDelaySequence() 217 assertTrue(c <= SMALL_DELAY_MS + SHORT_DELAY_MS); in testFixedDelaySequence() 343 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetActiveCount() 411 assertTrue(threadsStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetLargestPoolSize() 436 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetPoolSize() [all …]
|
D | JSR166TestCase.java | 115 public static long SMALL_DELAY_MS; field in JSR166TestCase 133 SMALL_DELAY_MS = SHORT_DELAY_MS * 5; in setDelays() 857 delay(SMALL_DELAY_MS); 864 delay(SMALL_DELAY_MS); 871 delay(SMALL_DELAY_MS); 953 delay(SMALL_DELAY_MS); 990 delay(SMALL_DELAY_MS);
|
D | PhaserTest.java | 681 assertEquals(-42, phaser.awaitAdvanceInterruptibly(-42, SMALL_DELAY_MS, MILLISECONDS)); 689 assertEquals(-42, phaser.awaitAdvanceInterruptibly(-42, SMALL_DELAY_MS, MILLISECONDS)); 692 assertEquals(1, phaser.awaitAdvanceInterruptibly(0, SMALL_DELAY_MS, MILLISECONDS)); 700 assertEquals(-42, phaser.awaitAdvanceInterruptibly(-42, SMALL_DELAY_MS, MILLISECONDS)); 703 assertEquals(2, phaser.awaitAdvanceInterruptibly(0, SMALL_DELAY_MS, MILLISECONDS)); 706 assertEquals(2, phaser.awaitAdvanceInterruptibly(1, SMALL_DELAY_MS, MILLISECONDS));
|
D | ThreadPoolExecutorTest.java | 71 assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); in testExecute() 96 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetActiveCount() 311 assertTrue(threadsStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetLargestPoolSize() 352 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetPoolSize() 378 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetTaskCount() 448 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testIsTerminated() 476 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testIsTerminating() 511 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetQueue() 543 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testRemove() 582 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testPurge() [all …]
|
D | ThreadPoolExecutorSubclassTest.java | 211 assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); in testExecute() 236 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetActiveCount() 418 assertTrue(threadsStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetLargestPoolSize() 456 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetPoolSize() 482 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetTaskCount() 520 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testIsTerminated() 549 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testIsTerminating() 584 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetQueue() 616 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testRemove() 655 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testPurge()
|
D | LinkedTransferQueueTest.java | 272 assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS); in testInterruptedTimedPoll() 285 waitForThreadToEnterWaitState(t, SMALL_DELAY_MS); in testInterruptedTimedPoll() 303 assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS); in testTimedPollAfterInterrupt() 714 waitForThreadToEnterWaitState(t, SMALL_DELAY_MS); in testWaitingConsumer() 753 waitForThreadToEnterWaitState(t, SMALL_DELAY_MS); in testTransfer2()
|
D | ForkJoinTaskTest.java | 96 assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS); in checkCompletedNormally() 104 assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS); in checkCompletedNormally() 139 assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS); 177 assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS);
|
D | PriorityBlockingQueueTest.java | 380 assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS); in testInterruptedTimedPoll() 393 waitForThreadToEnterWaitState(t, SMALL_DELAY_MS); in testInterruptedTimedPoll()
|
D | CountedCompleterTest.java | 95 assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS); in checkCompletedNormally() 103 assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS); in checkCompletedNormally() 138 assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS); 176 assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS);
|
D | LinkedBlockingQueueTest.java | 424 assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS); in testInterruptedTimedPoll() 437 waitForThreadToEnterWaitState(t, SMALL_DELAY_MS); in testInterruptedTimedPoll()
|
D | ArrayBlockingQueueTest.java | 435 assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS); in testInterruptedTimedPoll() 448 waitForThreadToEnterWaitState(t, SMALL_DELAY_MS); in testInterruptedTimedPoll()
|
D | LinkedBlockingDequeTest.java | 734 assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS); in testInterruptedTimedPoll() 747 waitForThreadToEnterWaitState(t, SMALL_DELAY_MS); in testInterruptedTimedPoll() 1040 q.pollFirst(SMALL_DELAY_MS, MILLISECONDS); in testInterruptedTimedPollFirst()
|