Home
last modified time | relevance | path

Searched refs:LONG_DELAY_MS (Results 1 – 25 of 43) sorted by relevance

12

/libcore/jsr166-tests/src/test/java/jsr166/
DThreadPoolExecutorTest.java25 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>()); in ExtendedTPE()
62 LONG_DELAY_MS, MILLISECONDS, in testExecute()
84 LONG_DELAY_MS, MILLISECONDS, in testGetActiveCount()
110 LONG_DELAY_MS, MILLISECONDS, in testPrestartCoreThread()
128 LONG_DELAY_MS, MILLISECONDS, in testPrestartAllCoreThreads()
145 LONG_DELAY_MS, MILLISECONDS, in testGetCompletedTaskCount()
165 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in testGetCompletedTaskCount()
180 LONG_DELAY_MS, MILLISECONDS, in testGetCorePoolSize()
205 LONG_DELAY_MS, MILLISECONDS, in testGetThreadFactory()
219 LONG_DELAY_MS, MILLISECONDS, in testSetThreadFactory()
[all …]
DThreadPoolExecutorSubclassTest.java165 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>()); in CustomTPE()
202 LONG_DELAY_MS, MILLISECONDS, in testExecute()
224 LONG_DELAY_MS, MILLISECONDS, in testGetActiveCount()
248 …ThreadPoolExecutor p = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Run… in testPrestartCoreThread()
263 …ThreadPoolExecutor p = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Run… in testPrestartAllCoreThreads()
279 LONG_DELAY_MS, MILLISECONDS, in testGetCompletedTaskCount()
299 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in testGetCompletedTaskCount()
312 …ThreadPoolExecutor p = new CustomTPE(1, 1, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Run… in testGetCorePoolSize()
331 …ThreadPoolExecutor p = new CustomTPE(1,2,LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runna… in testGetThreadFactory()
340 …ThreadPoolExecutor p = new CustomTPE(1,2,LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runna… in testSetThreadFactory()
[all …]
DBlockingQueueTest.java83 q.offer(null, LONG_DELAY_MS, MILLISECONDS); in testTimedOfferNull()
86 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedOfferNull()
215 assertSame(zero, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPollWithOffer()
219 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer()
226 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer()
234 assertTrue(q.offer(zero, LONG_DELAY_MS, MILLISECONDS)); in testTimedPollWithOffer()
235 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPollWithOffer()
294 q.poll(2 * LONG_DELAY_MS, MILLISECONDS);
316 q.poll(2 * LONG_DELAY_MS, MILLISECONDS);
DExchangerTest.java47 assertSame(one, e.exchange(two, LONG_DELAY_MS, MILLISECONDS)); in testTimedExchange()
48 assertSame(two, e.exchange(one, LONG_DELAY_MS, MILLISECONDS)); in testTimedExchange()
52 assertSame(two, e.exchange(one, LONG_DELAY_MS, MILLISECONDS)); in testTimedExchange()
53 assertSame(one, e.exchange(two, LONG_DELAY_MS, MILLISECONDS)); in testTimedExchange()
86 e.exchange(null, LONG_DELAY_MS, MILLISECONDS); in testTimedExchange_InterruptedException()
DLinkedBlockingDequeTest.java630 q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS); in testTimedOffer()
713 assertEquals(i, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
714 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPoll()
733 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
862 q.offerFirst(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS); in testTimedOfferFirst()
1016 assertEquals(i, q.pollFirst(LONG_DELAY_MS, MILLISECONDS)); in testTimedPollFirst()
1017 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPollFirst()
1035 assertEquals(i, q.pollFirst(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPollFirst()
1047 q.pollFirst(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPollFirst()
1074 assertSame(zero, q.pollFirst(LONG_DELAY_MS, MILLISECONDS)); in testTimedPollFirstWithOfferFirst()
[all …]
DJSR166TestCase.java117 public static long LONG_DELAY_MS; field in JSR166TestCase
135 LONG_DELAY_MS = SHORT_DELAY_MS * 200; in setDelays()
217 thread.join(LONG_DELAY_MS); in checkForkJoinPoolThreadLeaks()
389 exec.awaitTermination(2 * LONG_DELAY_MS, MILLISECONDS)); in joinPool()
620 waitForThreadToEnterWaitState(thread, LONG_DELAY_MS); in waitForThreadToEnterWaitState()
666 awaitTermination(t, LONG_DELAY_MS); in awaitTermination()
802 assertTrue(latch.await(LONG_DELAY_MS, MILLISECONDS));
810 assertTrue(semaphore.tryAcquire(LONG_DELAY_MS, MILLISECONDS));
908 delay(LONG_DELAY_MS);
973 delay(LONG_DELAY_MS);
[all …]
DTimeUnitTest.java342 tu.timedWait(o, LONG_DELAY_MS); in testTimedWait_IllegalMonitorException()
363 tu.timedWait(o, LONG_DELAY_MS); in testTimedWait_Interruptible()
372 tu.timedWait(o, LONG_DELAY_MS); in testTimedWait_Interruptible()
392 Thread.sleep(LONG_DELAY_MS); in testTimedJoin_Interruptible()
399 tu.timedJoin(s, LONG_DELAY_MS); in testTimedJoin_Interruptible()
406 tu.timedJoin(s, LONG_DELAY_MS); in testTimedJoin_Interruptible()
430 tu.sleep(LONG_DELAY_MS); in testTimedSleep_Interruptible()
437 tu.sleep(LONG_DELAY_MS); in testTimedSleep_Interruptible()
DCountDownLatchTest.java86 assertTrue(l.await(LONG_DELAY_MS, MILLISECONDS)); in testTimedAwait()
141 l.await(LONG_DELAY_MS, MILLISECONDS); in testTimedAwait_Interruptible()
148 l.await(LONG_DELAY_MS, MILLISECONDS); in testTimedAwait_Interruptible()
DFutureTaskTest.java291 assertSame(one, task.get(LONG_DELAY_MS, MILLISECONDS)); in testSet()
316 task.get(LONG_DELAY_MS, MILLISECONDS); in testSetException_get()
404 delay(LONG_DELAY_MS); in testCancelInterrupt()
478 delay(LONG_DELAY_MS); in testCancelInterrupt_taskFails()
546 assertSame(two, task.get(2*LONG_DELAY_MS, MILLISECONDS)); in testGetRun()
585 assertSame(two, task.get(2*LONG_DELAY_MS, MILLISECONDS)); in testGetSet()
621 delay(2*LONG_DELAY_MS); in testTimedGet_Cancellation()
638 task.get(2*LONG_DELAY_MS, MILLISECONDS); in testTimedGet_Cancellation()
694 task.get(LONG_DELAY_MS, MILLISECONDS); in testTimedGet_ExecutionException2()
742 task.get(2*LONG_DELAY_MS, MILLISECONDS); in testTimedGet_interruptible()
[all …]
DSynchronousQueueTest.java175 q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS); in testTimedOffer()
238 assertSame(zero, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPollWithOffer()
243 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer()
250 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer()
258 try { assertTrue(q.offer(zero, LONG_DELAY_MS, MILLISECONDS)); } in testTimedPollWithOffer()
464 assertTrue(q.offer(one, LONG_DELAY_MS, MILLISECONDS));
490 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS));
553 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
DAtomicMarkableReferenceTest.java101 t.join(LONG_DELAY_MS); in testCompareAndSetInMultipleThreads()
121 t.join(LONG_DELAY_MS); in testCompareAndSetInMultipleThreads2()
DAtomicStampedReferenceTest.java101 t.join(LONG_DELAY_MS); in testCompareAndSetInMultipleThreads()
121 t.join(LONG_DELAY_MS); in testCompareAndSetInMultipleThreads2()
DCyclicBarrierTest.java33 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in awaitNumberWaiting()
150 c.await(LONG_DELAY_MS, MILLISECONDS); in testAwait2_Interrupted_BrokenBarrier()
155 c.await(LONG_DELAY_MS, MILLISECONDS); in testAwait2_Interrupted_BrokenBarrier()
193 c.await(LONG_DELAY_MS, MILLISECONDS); in testAwait4_Timeout_BrokenBarrier()
DDelayQueueTest.java315 assertTrue(q.offer(new PDelay(0), LONG_DELAY_MS, MILLISECONDS)); in testTimedOffer()
393 assertEquals(new PDelay(i), ((PDelay)q.poll(LONG_DELAY_MS, MILLISECONDS))); in testTimedPoll()
394 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPoll()
417 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
424 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
646 assertNotNull(q.poll(LONG_DELAY_MS, MILLISECONDS)); in testPollInExecutor()
702 q.add(new NanoDelay(LONG_DELAY_MS * 1000000L)); in testTimedPollDelayed()
DExecutorsTest.java186 assertSame(Boolean.TRUE, f.get(LONG_DELAY_MS, MILLISECONDS)); in testNewSingleThreadScheduledExecutor()
212 assertSame(Boolean.TRUE, f.get(LONG_DELAY_MS, MILLISECONDS)); in testNewScheduledThreadPool()
240 assertSame(Boolean.TRUE, f.get(LONG_DELAY_MS, MILLISECONDS)); in testUnconfigurableScheduledExecutorService()
263 delay(LONG_DELAY_MS); in testTimedCallable()
DPriorityBlockingQueueTest.java281 assertTrue(q.offer(new Integer(0), LONG_DELAY_MS, MILLISECONDS)); in testTimedOffer()
359 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
360 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPoll()
379 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
385 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
607 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testPollInExecutor()
DLinkedTransferQueueTest.java251 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
252 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPoll()
271 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
302 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPollAfterInterrupt()
574 assertTrue(q.offer(one, LONG_DELAY_MS, MILLISECONDS)); in testOfferInExecutor()
599 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testPollInExecutor()
708 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testWaitingConsumer()
917 q.tryTransfer(new Object(), LONG_DELAY_MS, MILLISECONDS); in testTryTransfer5()
924 q.tryTransfer(new Object(), LONG_DELAY_MS, MILLISECONDS); in testTryTransfer5()
DScheduledExecutorTest.java75 assertNull(f.get(LONG_DELAY_MS, MILLISECONDS)); in testSchedule3()
97 LONG_DELAY_MS, MILLISECONDS); in testSchedule4()
121 LONG_DELAY_MS, MILLISECONDS); in testSchedule5()
325 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in testGetCompletedTaskCount()
490 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testIsTerminated()
515 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testIsTerminating()
589 LONG_DELAY_MS, MILLISECONDS); in testPurge()
618 LONG_DELAY_MS, MILLISECONDS); in testShutdownNow()
696 long initialDelay = LONG_DELAY_MS; in testShutdown3()
DScheduledExecutorSubclassTest.java127 assertNull(f.get(LONG_DELAY_MS, MILLISECONDS)); in testSchedule3()
149 LONG_DELAY_MS, MILLISECONDS); in testSchedule4()
173 LONG_DELAY_MS, MILLISECONDS); in testSchedule5()
375 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in testGetCompletedTaskCount()
539 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testIsTerminated()
564 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testIsTerminating()
638 LONG_DELAY_MS, MILLISECONDS); in testPurge()
667 LONG_DELAY_MS, MILLISECONDS); in testShutdownNow()
745 long initialDelay = LONG_DELAY_MS; in testShutdown3()
DSemaphoreTest.java67 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in waitForQueuedThread()
81 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in waitForQueuedThreads()
120 assertTrue(s.tryAcquire(2 * LONG_DELAY_MS, MILLISECONDS)); in tryAcquireTimed()
125 assertTrue(s.tryAcquire(permits, 2 * LONG_DELAY_MS, MILLISECONDS)); in acquire()
570 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testReleaseAcquireDifferentThreads()
DLinkedBlockingQueueTest.java320 q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS); in testTimedOffer()
403 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
404 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPoll()
423 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
694 assertTrue(q.offer(three, LONG_DELAY_MS, MILLISECONDS)); in testOfferInExecutor()
718 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testPollInExecutor()
DLockSupportTest.java67 void park() { park(2 * LONG_DELAY_MS); } in park()
304 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in testGetBlocker()
DArrayBlockingQueueTest.java330 q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS); in testTimedOffer()
414 assertEquals(i, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
415 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPoll()
434 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
760 assertTrue(q.offer(three, LONG_DELAY_MS, MILLISECONDS)); in testOfferInExecutor()
785 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testPollInExecutor()
DAtomicBooleanTest.java84 t.join(LONG_DELAY_MS); in testCompareAndSetInMultipleThreads()
DAtomicReferenceTest.java84 t.join(LONG_DELAY_MS); in testCompareAndSetInMultipleThreads()

12