Home
last modified time | relevance | path

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

12

/libcore/jsr166-tests/src/test/java/jsr166/
DThreadPoolExecutorTest.java56 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>()); in ExtendedTPE()
93 LONG_DELAY_MS, MILLISECONDS, in testExecute()
100 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS)); in testExecute()
112 LONG_DELAY_MS, MILLISECONDS, in testGetActiveCount()
134 LONG_DELAY_MS, MILLISECONDS, in testPrestartCoreThread()
160 LONG_DELAY_MS, MILLISECONDS, in testPrestartAllCoreThreads()
183 LONG_DELAY_MS, MILLISECONDS, in testGetCompletedTaskCount()
203 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in testGetCompletedTaskCount()
216 LONG_DELAY_MS, MILLISECONDS, in testGetCorePoolSize()
243 LONG_DELAY_MS, MILLISECONDS, in testGetThreadFactory()
[all …]
DThreadPoolExecutorSubclassTest.java203 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>()); in CustomTPE()
240 2 * LONG_DELAY_MS, MILLISECONDS, in testExecute()
247 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS)); in testExecute()
259 LONG_DELAY_MS, MILLISECONDS, in testGetActiveCount()
281 LONG_DELAY_MS, MILLISECONDS, in testPrestartCoreThread()
307 LONG_DELAY_MS, MILLISECONDS, in testPrestartAllCoreThreads()
330 LONG_DELAY_MS, MILLISECONDS, in testGetCompletedTaskCount()
350 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in testGetCompletedTaskCount()
363 LONG_DELAY_MS, MILLISECONDS, in testGetCorePoolSize()
390 LONG_DELAY_MS, MILLISECONDS, in testGetThreadFactory()
[all …]
DBlockingQueueTest.java95 q.offer(null, LONG_DELAY_MS, MILLISECONDS); in testTimedOfferNull()
98 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedOfferNull()
227 assertSame(zero, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPollWithOffer()
231 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer()
238 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer()
243 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPollWithOffer()
248 assertTrue(q.offer(zero, LONG_DELAY_MS, MILLISECONDS)); in testTimedPollWithOffer()
249 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPollWithOffer()
308 q.poll(2 * LONG_DELAY_MS, MILLISECONDS);
330 q.poll(2 * LONG_DELAY_MS, MILLISECONDS);
DExchangerTest.java59 assertSame(one, e.exchange(two, LONG_DELAY_MS, MILLISECONDS)); in testTimedExchange()
60 assertSame(two, e.exchange(one, LONG_DELAY_MS, MILLISECONDS)); in testTimedExchange()
64 assertSame(two, e.exchange(one, LONG_DELAY_MS, MILLISECONDS)); in testTimedExchange()
65 assertSame(one, e.exchange(two, LONG_DELAY_MS, MILLISECONDS)); in testTimedExchange()
98 e.exchange(null, LONG_DELAY_MS, MILLISECONDS); in testTimedExchange_InterruptedException()
DScheduledExecutorTest.java59 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS)); in testExecute()
99 assertNull(f.get(LONG_DELAY_MS, MILLISECONDS)); in testSchedule3()
119 LONG_DELAY_MS, MILLISECONDS); in testSchedule4()
141 LONG_DELAY_MS, MILLISECONDS); in testSchedule5()
161 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) { in testFixedRateSequence()
170 await(done, totalDelayMillis + LONG_DELAY_MS); in testFixedRateSequence()
190 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) { in testFixedDelaySequence()
216 await(done, totalDelayMillis + cycles * LONG_DELAY_MS); in testFixedDelaySequence()
380 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in testGetCompletedTaskCount()
549 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testIsTerminated()
[all …]
DScheduledExecutorSubclassTest.java155 assertNull(f.get(LONG_DELAY_MS, MILLISECONDS)); in testSchedule3()
175 LONG_DELAY_MS, MILLISECONDS); in testSchedule4()
197 LONG_DELAY_MS, MILLISECONDS); in testSchedule5()
217 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) { in testFixedRateSequence()
226 await(done, totalDelayMillis + LONG_DELAY_MS); in testFixedRateSequence()
246 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) { in testFixedDelaySequence()
272 await(done, totalDelayMillis + cycles * LONG_DELAY_MS); in testFixedDelaySequence()
436 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in testGetCompletedTaskCount()
601 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testIsTerminated()
625 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testIsTerminating()
[all …]
DLinkedBlockingDequeTest.java657 q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS); in testTimedOffer()
740 assertEquals(i, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
741 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPoll()
760 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
764 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
767 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testInterruptedTimedPoll()
772 waitForThreadToEnterWaitState(t, LONG_DELAY_MS); in testInterruptedTimedPoll()
887 q.offerFirst(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS); in testTimedOfferFirst()
1041 assertEquals(i, q.pollFirst(LONG_DELAY_MS, MILLISECONDS)); in testTimedPollFirst()
1042 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPollFirst()
[all …]
DLinkedTransferQueueTest.java278 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
279 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPoll()
298 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
301 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
304 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testInterruptedTimedPoll()
325 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPollAfterInterrupt()
327 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollAfterInterrupt()
330 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPollAfterInterrupt()
611 assertTrue(q.offer(one, LONG_DELAY_MS, MILLISECONDS)); in testOfferInExecutor()
612 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testOfferInExecutor()
[all …]
DTimeUnitTest.java325 tu.timedWait(o, LONG_DELAY_MS); in testTimedWait_IllegalMonitorException()
346 tu.timedWait(o, LONG_DELAY_MS); in testTimedWait_Interruptible()
355 tu.timedWait(o, LONG_DELAY_MS); in testTimedWait_Interruptible()
375 Thread.sleep(LONG_DELAY_MS); in testTimedJoin_Interruptible()
382 tu.timedJoin(s, LONG_DELAY_MS); in testTimedJoin_Interruptible()
389 tu.timedJoin(s, LONG_DELAY_MS); in testTimedJoin_Interruptible()
413 tu.sleep(LONG_DELAY_MS); in testTimedSleep_Interruptible()
420 tu.sleep(LONG_DELAY_MS); in testTimedSleep_Interruptible()
DSynchronousQueueTest.java203 q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS); in testTimedOffer()
266 assertSame(zero, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPollWithOffer()
270 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer()
277 q.poll(LONG_DELAY_MS, MILLISECONDS); in testTimedPollWithOffer()
282 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPollWithOffer()
287 try { assertTrue(q.offer(zero, LONG_DELAY_MS, MILLISECONDS)); } in testTimedPollWithOffer()
289 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPollWithOffer()
488 assertTrue(q.offer(one, LONG_DELAY_MS, MILLISECONDS));
514 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS));
576 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
DJSR166TestCase.java575 public static long LONG_DELAY_MS; field in JSR166TestCase
594 LONG_DELAY_MS = SHORT_DELAY_MS * 200; in setDelays()
686 thread.join(LONG_DELAY_MS); in checkForkJoinPoolThreadLeaks()
694 .awaitQuiescence(LONG_DELAY_MS, MILLISECONDS)) in checkForkJoinPoolThreadLeaks()
911 if (!pool.awaitTermination(2 * LONG_DELAY_MS, MILLISECONDS)) {
945 assertNull(future.get(LONG_DELAY_MS, MILLISECONDS));
1265 waitForThreadToEnterWaitState(thread, LONG_DELAY_MS);
1275 waitForThreadToEnterWaitState(thread, LONG_DELAY_MS, waitingForGodot);
1314 checkTimedGet(f, expectedValue, LONG_DELAY_MS);
1351 awaitTermination(t, LONG_DELAY_MS);
[all …]
DCountDownLatchTest.java97 assertTrue(l.await(LONG_DELAY_MS, MILLISECONDS)); in testTimedAwait()
152 l.await(LONG_DELAY_MS, MILLISECONDS); in testTimedAwait_Interruptible()
159 l.await(LONG_DELAY_MS, MILLISECONDS); in testTimedAwait_Interruptible()
DFutureTaskTest.java309 assertSame(one, task.get(LONG_DELAY_MS, MILLISECONDS)); in testSet()
334 task.get(LONG_DELAY_MS, MILLISECONDS); in testSetException_get()
422 delay(LONG_DELAY_MS); in testCancelInterrupt()
496 delay(LONG_DELAY_MS); in testCancelInterrupt_taskFails()
564 assertSame(two, task.get(2*LONG_DELAY_MS, MILLISECONDS)); in testGetRun()
603 assertSame(two, task.get(2*LONG_DELAY_MS, MILLISECONDS)); in testGetSet()
639 delay(2*LONG_DELAY_MS); in testTimedGet_Cancellation()
656 task.get(2*LONG_DELAY_MS, MILLISECONDS); in testTimedGet_Cancellation()
712 task.get(LONG_DELAY_MS, MILLISECONDS); in testTimedGet_ExecutionException2()
760 task.get(2*LONG_DELAY_MS, MILLISECONDS); in testTimedGet_interruptible()
[all …]
DAbstractExecutorServiceTest.java202 assertTrue(quittingTime.await(2*LONG_DELAY_MS, MILLISECONDS)); in testInterruptedSubmit()
461 e.invokeAny(l, LONG_DELAY_MS, MILLISECONDS); in testTimedInvokeAny4()
466 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedInvokeAny4()
480 String result = e.invokeAny(l, LONG_DELAY_MS, MILLISECONDS);
482 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
550 e.invokeAll(l, LONG_DELAY_MS, MILLISECONDS);
571 e.invokeAll(l, LONG_DELAY_MS, MILLISECONDS);
603 if (timeout >= LONG_DELAY_MS / 2)
DDelayQueueTest.java337 assertTrue(q.offer(new PDelay(0), LONG_DELAY_MS, MILLISECONDS)); in testTimedOffer()
415 assertEquals(new PDelay(i), q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
416 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPoll()
436 ((PDelay)q.poll(LONG_DELAY_MS, MILLISECONDS))); in testInterruptedTimedPoll()
441 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
448 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
452 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testInterruptedTimedPoll()
681 assertNotNull(q.poll(LONG_DELAY_MS, MILLISECONDS)); in testPollInExecutor()
736 q.add(new NanoDelay(LONG_DELAY_MS * 1000000L)); in testTimedPollDelayed()
DPriorityBlockingQueueTest.java307 assertTrue(q.offer(new Integer(0), LONG_DELAY_MS, MILLISECONDS)); in testTimedOffer()
385 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
386 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPoll()
405 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
409 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
412 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testInterruptedTimedPoll()
417 waitForThreadToEnterWaitState(t, LONG_DELAY_MS); in testInterruptedTimedPoll()
638 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testPollInExecutor()
DForkJoinPoolTest.java266 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testAwaitTermination_timesOut()
315 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in testIsQuiescent()
330 && millisElapsedSince(startTime) < LONG_DELAY_MS) in testIsQuiescent()
337 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testIsQuiescent()
576 assertTrue(quittingTime.await(2*LONG_DELAY_MS, MILLISECONDS)); in testInterruptedSubmit()
849 e.invokeAny(l, LONG_DELAY_MS, MILLISECONDS); in testTimedInvokeAny4()
854 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedInvokeAny4()
868 String result = e.invokeAny(l, LONG_DELAY_MS, MILLISECONDS);
870 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
940 = e.invokeAll(l, LONG_DELAY_MS, MILLISECONDS);
[all …]
DLinkedBlockingQueueTest.java349 q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS); in testTimedOffer()
432 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
433 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPoll()
452 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
456 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
459 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testInterruptedTimedPoll()
464 waitForThreadToEnterWaitState(t, LONG_DELAY_MS); in testInterruptedTimedPoll()
737 assertTrue(q.offer(three, LONG_DELAY_MS, MILLISECONDS)); in testOfferInExecutor()
761 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testPollInExecutor()
DCyclicBarrierTest.java44 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in awaitNumberWaiting()
161 c.await(LONG_DELAY_MS, MILLISECONDS); in testAwait2_Interrupted_BrokenBarrier()
166 c.await(LONG_DELAY_MS, MILLISECONDS); in testAwait2_Interrupted_BrokenBarrier()
204 c.await(LONG_DELAY_MS, MILLISECONDS); in testAwait4_Timeout_BrokenBarrier()
DAtomicMarkableReferenceTest.java112 t.join(LONG_DELAY_MS); in testCompareAndSetInMultipleThreads()
132 t.join(LONG_DELAY_MS); in testCompareAndSetInMultipleThreads2()
DAtomicStampedReferenceTest.java112 t.join(LONG_DELAY_MS); in testCompareAndSetInMultipleThreads()
132 t.join(LONG_DELAY_MS); in testCompareAndSetInMultipleThreads2()
DArrayBlockingQueueTest.java359 q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS); in testTimedOffer()
443 assertEquals(i, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testTimedPoll()
444 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testTimedPoll()
463 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS)); in testInterruptedTimedPoll()
467 q.poll(LONG_DELAY_MS, MILLISECONDS); in testInterruptedTimedPoll()
470 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testInterruptedTimedPoll()
475 waitForThreadToEnterWaitState(t, LONG_DELAY_MS); in testInterruptedTimedPoll()
803 assertTrue(q.offer(three, LONG_DELAY_MS, MILLISECONDS)); in testOfferInExecutor()
828 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS)); in testPollInExecutor()
DForkJoinPool8Test.java1037 assertNull(f.get(LONG_DELAY_MS, MILLISECONDS)); in testForkTimedGetCC()
1153 f.get(LONG_DELAY_MS, MILLISECONDS); in testAbnormalForkTimedGetCC()
1245 f.get(LONG_DELAY_MS, MILLISECONDS); in testCancelledForkTimedGetCC()
1504 boolean quiescent = p.awaitQuiescence(LONG_DELAY_MS, MILLISECONDS); in testAwaitQuiescence1()
1514 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testAwaitQuiescence1()
1532 && millisElapsedSince(startTime) < LONG_DELAY_MS) in testAwaitQuiescence1()
1537 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testAwaitQuiescence1()
1563 && millisElapsedSince(startTime) < LONG_DELAY_MS) {
1570 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1575 assertTrue(p.awaitQuiescence(LONG_DELAY_MS, MILLISECONDS));
[all …]
DExecutorsTest.java215 assertSame(Boolean.TRUE, f.get(LONG_DELAY_MS, MILLISECONDS)); in testNewSingleThreadScheduledExecutor()
239 assertSame(Boolean.TRUE, f.get(LONG_DELAY_MS, MILLISECONDS)); in testNewScheduledThreadPool()
265 assertSame(Boolean.TRUE, f.get(LONG_DELAY_MS, MILLISECONDS)); in testUnconfigurableScheduledExecutorService()
286 delay(LONG_DELAY_MS); in testTimedCallable()
DSemaphoreTest.java80 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in waitForQueuedThread()
94 if (millisElapsedSince(startTime) > LONG_DELAY_MS) in waitForQueuedThreads()
133 assertTrue(s.tryAcquire(2 * LONG_DELAY_MS, MILLISECONDS)); in tryAcquireTimed()
138 assertTrue(s.tryAcquire(permits, 2 * LONG_DELAY_MS, MILLISECONDS)); in acquire()
588 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); in testReleaseAcquireDifferentThreads()

12