| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ThreadPoolExecutorTest.java | 53 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>());
90 LONG_DELAY_MS, MILLISECONDS,
112 LONG_DELAY_MS, MILLISECONDS,
138 LONG_DELAY_MS, MILLISECONDS,
156 LONG_DELAY_MS, MILLISECONDS,
173 LONG_DELAY_MS, MILLISECONDS,
193 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
208 LONG_DELAY_MS, MILLISECONDS,
233 LONG_DELAY_MS, MILLISECONDS,
247 LONG_DELAY_MS, MILLISECONDS
[all...] |
| ThreadPoolExecutorSubclassTest.java | 195 super(1, 1, LONG_DELAY_MS, MILLISECONDS, new SynchronousQueue<Runnable>());
232 LONG_DELAY_MS, MILLISECONDS,
254 LONG_DELAY_MS, MILLISECONDS,
278 ThreadPoolExecutor p = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
293 ThreadPoolExecutor p = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
309 LONG_DELAY_MS, MILLISECONDS,
329 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
342 ThreadPoolExecutor p = new CustomTPE(1, 1, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
361 ThreadPoolExecutor p = new CustomTPE(1,2,LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10), tf, new NoOpREHandler());
370 ThreadPoolExecutor p = new CustomTPE(1,2,LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10))
[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);
246 assertTrue(q.offer(zero, LONG_DELAY_MS, MILLISECONDS));
247 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
306 q.poll(2 * LONG_DELAY_MS, MILLISECONDS);
328 q.poll(2 * LONG_DELAY_MS, MILLISECONDS);
|
| 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);
|
| LinkedBlockingDequeTest.java | 658 q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
741 assertEquals(i, q.poll(LONG_DELAY_MS, MILLISECONDS));
742 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
761 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
890 q.offerFirst(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
[all...] |
| 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);
|
| SynchronousQueueTest.java | 201 q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
264 assertSame(zero, q.poll(LONG_DELAY_MS, MILLISECONDS));
269 q.poll(LONG_DELAY_MS, MILLISECONDS);
276 q.poll(LONG_DELAY_MS, MILLISECONDS);
284 try { assertTrue(q.offer(zero, LONG_DELAY_MS, MILLISECONDS)); }
484 assertTrue(q.offer(one, LONG_DELAY_MS, MILLISECONDS));
510 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS));
573 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
|
| JSR166TestCase.java | 80 * {@code LONG_DELAY_MS}. The idea here is that a SHORT is always
136 public static long LONG_DELAY_MS;
153 LONG_DELAY_MS = SHORT_DELAY_MS * 200;
235 thread.join(LONG_DELAY_MS);
406 if (!exec.awaitTermination(2 * LONG_DELAY_MS, MILLISECONDS))
644 * Waits up to LONG_DELAY_MS for the given thread to enter a wait
648 waitForThreadToEnterWaitState(thread, LONG_DELAY_MS);
670 // assertTerminatesPromptly(LONG_DELAY_MS/2, r);
687 checkTimedGet(f, expectedValue, LONG_DELAY_MS);
719 * Waits for LONG_DELAY_MS milliseconds for the thread t
[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...] |
| ScheduledExecutorTest.java | 99 assertNull(f.get(LONG_DELAY_MS, MILLISECONDS));
121 LONG_DELAY_MS, MILLISECONDS);
145 LONG_DELAY_MS, MILLISECONDS);
165 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) {
193 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) {
371 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
536 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS));
561 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS));
635 LONG_DELAY_MS, MILLISECONDS);
664 LONG_DELAY_MS, MILLISECONDS)
[all...] |
| PriorityBlockingQueueTest.java | 305 assertTrue(q.offer(new Integer(0), LONG_DELAY_MS, MILLISECONDS));
383 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
384 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
403 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
409 q.poll(LONG_DELAY_MS, MILLISECONDS);
637 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);
|
| ExecutorsTest.java | 209 assertSame(Boolean.TRUE, f.get(LONG_DELAY_MS, MILLISECONDS));
235 assertSame(Boolean.TRUE, f.get(LONG_DELAY_MS, MILLISECONDS));
263 assertSame(Boolean.TRUE, f.get(LONG_DELAY_MS, MILLISECONDS));
286 delay(LONG_DELAY_MS);
|
| LinkedTransferQueueTest.java | 270 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
271 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
290 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
321 assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
606 assertTrue(q.offer(one, LONG_DELAY_MS, MILLISECONDS));
631 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS));
739 assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS));
948 q.tryTransfer(new Object(), LONG_DELAY_MS, MILLISECONDS);
955 q.tryTransfer(new Object(), LONG_DELAY_MS, MILLISECONDS);
[all...] |
| ScheduledExecutorSubclassTest.java | 156 assertNull(f.get(LONG_DELAY_MS, MILLISECONDS));
178 LONG_DELAY_MS, MILLISECONDS);
202 LONG_DELAY_MS, MILLISECONDS);
222 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) {
250 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) {
426 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
590 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS));
615 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS));
689 LONG_DELAY_MS, MILLISECONDS);
718 LONG_DELAY_MS, MILLISECONDS)
[all...] |
| LockSupportTest.java | 79 void park() { park(2 * LONG_DELAY_MS); }
316 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
|
| SemaphoreTest.java | 79 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
93 if (millisElapsedSince(startTime) > LONG_DELAY_MS)
132 assertTrue(s.tryAcquire(2 * LONG_DELAY_MS, MILLISECONDS));
137 assertTrue(s.tryAcquire(permits, 2 * LONG_DELAY_MS, MILLISECONDS));
582 assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
|
| 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);
439 q.poll(LONG_DELAY_MS, MILLISECONDS);
446 q.poll(LONG_DELAY_MS, MILLISECONDS);
676 assertNotNull(q.poll(LONG_DELAY_MS, MILLISECONDS));
732 q.add(new NanoDelay(LONG_DELAY_MS * 1000000L));
|
| AtomicIntegerFieldUpdaterTest.java | 128 t.join(LONG_DELAY_MS);
|
| AtomicLongFieldUpdaterTest.java | 129 t.join(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...] |
