| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ThreadPoolExecutorTest.java | 56 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>());
93 LONG_DELAY_MS, MILLISECONDS,
100 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS));
112 LONG_DELAY_MS, MILLISECONDS,
134 LONG_DELAY_MS, MILLISECONDS,
160 LONG_DELAY_MS, MILLISECONDS,
183 LONG_DELAY_MS, MILLISECONDS,
203 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
216 LONG_DELAY_MS, MILLISECONDS,
243 LONG_DELAY_MS, MILLISECONDS
[all...] |
| ThreadPoolExecutorSubclassTest.java | 203 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>());
240 2 * LONG_DELAY_MS, MILLISECONDS,
247 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS));
259 LONG_DELAY_MS, MILLISECONDS,
281 LONG_DELAY_MS, MILLISECONDS,
307 LONG_DELAY_MS, MILLISECONDS,
330 LONG_DELAY_MS, MILLISECONDS,
350 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
363 LONG_DELAY_MS, MILLISECONDS,
390 LONG_DELAY_MS, MILLISECONDS
[all...] |
| ExchangerTest.java | 59 assertSame(one, e.exchange(two, LONG_DELAY_MS, MILLISECONDS));
60 assertSame(two, e.exchange(one, LONG_DELAY_MS, MILLISECONDS));
64 assertSame(two, e.exchange(one, LONG_DELAY_MS, MILLISECONDS));
65 assertSame(one, e.exchange(two, LONG_DELAY_MS, MILLISECONDS));
98 e.exchange(null, LONG_DELAY_MS, MILLISECONDS);
|
| BlockingQueueTest.java | 95 q.offer(null, LONG_DELAY_MS, MILLISECONDS);
98 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
227 assertSame(zero, q.poll(LONG_DELAY_MS, MILLISECONDS));
231 q.poll(LONG_DELAY_MS, MILLISECONDS);
238 q.poll(LONG_DELAY_MS, MILLISECONDS);
243 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
248 assertTrue(q.offer(zero, LONG_DELAY_MS, MILLISECONDS));
249 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
308 q.poll(2 * LONG_DELAY_MS, MILLISECONDS);
330 q.poll(2 * LONG_DELAY_MS, MILLISECONDS)
[all...] |
| ScheduledExecutorTest.java | 59 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS));
99 assertNull(f.get(LONG_DELAY_MS, MILLISECONDS));
119 LONG_DELAY_MS, MILLISECONDS);
141 LONG_DELAY_MS, MILLISECONDS);
161 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) {
170 await(done, totalDelayMillis + LONG_DELAY_MS);
190 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) {
216 await(done, totalDelayMillis + cycles * LONG_DELAY_MS);
380 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
549 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS))
[all...] |
| LinkedTransferQueueTest.java | 277 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
278 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
297 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
300 q.poll(LONG_DELAY_MS, MILLISECONDS);
303 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
324 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
326 q.poll(LONG_DELAY_MS, MILLISECONDS);
329 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
610 assertTrue(q.offer(one, LONG_DELAY_MS, MILLISECONDS));
611 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
[all...] |
| ScheduledExecutorSubclassTest.java | 155 assertNull(f.get(LONG_DELAY_MS, MILLISECONDS));
175 LONG_DELAY_MS, MILLISECONDS);
197 LONG_DELAY_MS, MILLISECONDS);
217 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) {
226 await(done, totalDelayMillis + LONG_DELAY_MS);
246 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) {
272 await(done, totalDelayMillis + cycles * LONG_DELAY_MS);
436 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
601 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS));
625 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS))
[all...] |
| LinkedBlockingDequeTest.java | 657 q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
740 assertEquals(i, q.poll(LONG_DELAY_MS, MILLISECONDS));
741 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
760 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
764 q.poll(LONG_DELAY_MS, MILLISECONDS);
767 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
772 waitForThreadToEnterWaitState(t, LONG_DELAY_MS);
887 q.offerFirst(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
[all...] |
| CountDownLatchTest.java | 97 assertTrue(l.await(LONG_DELAY_MS, MILLISECONDS));
152 l.await(LONG_DELAY_MS, MILLISECONDS);
159 l.await(LONG_DELAY_MS, MILLISECONDS);
|
| TimeUnitTest.java | 325 tu.timedWait(o, LONG_DELAY_MS);
346 tu.timedWait(o, LONG_DELAY_MS);
355 tu.timedWait(o, LONG_DELAY_MS);
375 Thread.sleep(LONG_DELAY_MS);
382 tu.timedJoin(s, LONG_DELAY_MS);
389 tu.timedJoin(s, LONG_DELAY_MS);
413 tu.sleep(LONG_DELAY_MS);
420 tu.sleep(LONG_DELAY_MS);
|
| SynchronousQueueTest.java | 203 q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
266 assertSame(zero, q.poll(LONG_DELAY_MS, MILLISECONDS));
270 q.poll(LONG_DELAY_MS, MILLISECONDS);
277 q.poll(LONG_DELAY_MS, MILLISECONDS);
282 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
287 try { assertTrue(q.offer(zero, LONG_DELAY_MS, MILLISECONDS)); }
289 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
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)
[all...] |
| JSR166TestCase.java | 90 * {@code LONG_DELAY_MS}. The idea here is that a SHORT is always
575 public static long LONG_DELAY_MS;
594 LONG_DELAY_MS = SHORT_DELAY_MS * 200;
686 thread.join(LONG_DELAY_MS);
694 .awaitQuiescence(LONG_DELAY_MS, MILLISECONDS))
[all...] |
| AbstractExecutorServiceTest.java | 202 assertTrue(quittingTime.await(2*LONG_DELAY_MS, MILLISECONDS));
461 e.invokeAny(l, LONG_DELAY_MS, MILLISECONDS);
466 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
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)
|
| AtomicMarkableReferenceTest.java | 112 t.join(LONG_DELAY_MS);
132 t.join(LONG_DELAY_MS);
|
| AtomicStampedReferenceTest.java | 112 t.join(LONG_DELAY_MS);
132 t.join(LONG_DELAY_MS);
|
| PriorityBlockingQueueTest.java | 307 assertTrue(q.offer(new Integer(0), LONG_DELAY_MS, MILLISECONDS));
385 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
386 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
405 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
409 q.poll(LONG_DELAY_MS, MILLISECONDS);
412 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
417 waitForThreadToEnterWaitState(t, LONG_DELAY_MS);
638 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS));
|
| ForkJoinPoolTest.java | 266 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS));
315 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
330 && millisElapsedSince(startTime) < LONG_DELAY_MS)
337 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
576 assertTrue(quittingTime.await(2*LONG_DELAY_MS, MILLISECONDS));
849 e.invokeAny(l, LONG_DELAY_MS, MILLISECONDS);
854 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
868 String result = e.invokeAny(l, LONG_DELAY_MS, MILLISECONDS);
870 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
[all...] |
| FutureTaskTest.java | 309 assertSame(one, task.get(LONG_DELAY_MS, MILLISECONDS));
334 task.get(LONG_DELAY_MS, MILLISECONDS);
422 delay(LONG_DELAY_MS);
496 delay(LONG_DELAY_MS);
564 assertSame(two, task.get(2*LONG_DELAY_MS, MILLISECONDS));
603 assertSame(two, task.get(2*LONG_DELAY_MS, MILLISECONDS));
639 delay(2*LONG_DELAY_MS);
656 task.get(2*LONG_DELAY_MS, MILLISECONDS);
712 task.get(LONG_DELAY_MS, MILLISECONDS);
760 task.get(2*LONG_DELAY_MS, MILLISECONDS)
[all...] |
| ForkJoinPool8Test.java | [all...] |
| ArrayBlockingQueueTest.java | 359 q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
443 assertEquals(i, q.poll(LONG_DELAY_MS, MILLISECONDS));
444 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
463 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
467 q.poll(LONG_DELAY_MS, MILLISECONDS);
470 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
475 waitForThreadToEnterWaitState(t, LONG_DELAY_MS);
803 assertTrue(q.offer(three, LONG_DELAY_MS, MILLISECONDS));
828 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS));
|
| AtomicBooleanTest.java | 95 t.join(LONG_DELAY_MS);
|
| CyclicBarrierTest.java | 44 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
161 c.await(LONG_DELAY_MS, MILLISECONDS);
166 c.await(LONG_DELAY_MS, MILLISECONDS);
204 c.await(LONG_DELAY_MS, MILLISECONDS);
|
| DelayQueueTest.java | 337 assertTrue(q.offer(new PDelay(0), LONG_DELAY_MS, MILLISECONDS));
415 assertEquals(new PDelay(i), q.poll(LONG_DELAY_MS, MILLISECONDS));
416 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
436 ((PDelay)q.poll(LONG_DELAY_MS, MILLISECONDS)));
441 q.poll(LONG_DELAY_MS, MILLISECONDS);
448 q.poll(LONG_DELAY_MS, MILLISECONDS);
452 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
681 assertNotNull(q.poll(LONG_DELAY_MS, MILLISECONDS));
736 q.add(new NanoDelay(LONG_DELAY_MS * 1000000L));
|
| ExecutorsTest.java | 215 assertSame(Boolean.TRUE, f.get(LONG_DELAY_MS, MILLISECONDS));
239 assertSame(Boolean.TRUE, f.get(LONG_DELAY_MS, MILLISECONDS));
265 assertSame(Boolean.TRUE, f.get(LONG_DELAY_MS, MILLISECONDS));
286 delay(LONG_DELAY_MS);
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| JSR166TestCase.java | 67 * {@code LONG_DELAY_MS}. The idea here is that a SHORT is always
262 public static long LONG_DELAY_MS;
279 LONG_DELAY_MS = SHORT_DELAY_MS * 200;
510 exec.awaitTermination(2 * LONG_DELAY_MS, MILLISECONDS));
745 * Waits up to LONG_DELAY_MS for the given thread to enter a wait
749 waitForThreadToEnterWaitState(thread, LONG_DELAY_MS);
790 * Waits for LONG_DELAY_MS milliseconds for the thread to
795 awaitTermination(t, LONG_DELAY_MS);
931 assertTrue(latch.await(LONG_DELAY_MS, MILLISECONDS));
939 assertTrue(semaphore.tryAcquire(LONG_DELAY_MS, MILLISECONDS))
[all...] |
