95 |
|
*/ |
96 |
|
public void testSchedule1() throws Exception { |
97 |
|
CustomExecutor p = new CustomExecutor(1); |
98 |
< |
final long t0 = System.nanoTime(); |
99 |
< |
final long timeoutNanos = SHORT_DELAY_MS * 1000L * 1000L; |
98 |
> |
final long startTime = System.nanoTime(); |
99 |
|
final CountDownLatch done = new CountDownLatch(1); |
100 |
|
try { |
101 |
|
Callable task = new CheckedCallable<Boolean>() { |
102 |
|
public Boolean realCall() { |
103 |
|
done.countDown(); |
104 |
< |
assertTrue(System.nanoTime() - t0 >= timeoutNanos); |
104 |
> |
assertTrue(millisElapsedSince(startTime) >= timeoutMillis()); |
105 |
|
return Boolean.TRUE; |
106 |
|
}}; |
107 |
< |
Future f = p.schedule(task, SHORT_DELAY_MS, MILLISECONDS); |
108 |
< |
assertEquals(Boolean.TRUE, f.get()); |
109 |
< |
assertTrue(System.nanoTime() - t0 >= timeoutNanos); |
107 |
> |
Future f = p.schedule(task, timeoutMillis(), MILLISECONDS); |
108 |
> |
assertSame(Boolean.TRUE, f.get()); |
109 |
> |
assertTrue(millisElapsedSince(startTime) >= timeoutMillis()); |
110 |
|
assertTrue(done.await(0L, MILLISECONDS)); |
111 |
|
} finally { |
112 |
|
joinPool(p); |
118 |
|
*/ |
119 |
|
public void testSchedule3() throws Exception { |
120 |
|
CustomExecutor p = new CustomExecutor(1); |
121 |
< |
final long t0 = System.nanoTime(); |
123 |
< |
final long timeoutNanos = SHORT_DELAY_MS * 1000L * 1000L; |
121 |
> |
final long startTime = System.nanoTime(); |
122 |
|
final CountDownLatch done = new CountDownLatch(1); |
123 |
|
try { |
124 |
|
Runnable task = new CheckedRunnable() { |
125 |
|
public void realRun() { |
126 |
|
done.countDown(); |
127 |
< |
assertTrue(System.nanoTime() - t0 >= timeoutNanos); |
127 |
> |
assertTrue(millisElapsedSince(startTime) >= timeoutMillis()); |
128 |
|
}}; |
129 |
< |
Future f = p.schedule(task, SHORT_DELAY_MS, MILLISECONDS); |
130 |
< |
assertNull(f.get()); |
131 |
< |
assertTrue(System.nanoTime() - t0 >= timeoutNanos); |
132 |
< |
assertTrue(done.await(0L, MILLISECONDS)); |
129 |
> |
Future f = p.schedule(task, timeoutMillis(), MILLISECONDS); |
130 |
> |
await(done); |
131 |
> |
assertNull(f.get(LONG_DELAY_MS, MILLISECONDS)); |
132 |
> |
assertTrue(millisElapsedSince(startTime) >= timeoutMillis()); |
133 |
|
} finally { |
134 |
|
joinPool(p); |
135 |
|
} |
140 |
|
*/ |
141 |
|
public void testSchedule4() throws InterruptedException { |
142 |
|
CustomExecutor p = new CustomExecutor(1); |
143 |
< |
final long t0 = System.nanoTime(); |
146 |
< |
final long timeoutNanos = SHORT_DELAY_MS * 1000L * 1000L; |
143 |
> |
final long startTime = System.nanoTime(); |
144 |
|
final CountDownLatch done = new CountDownLatch(1); |
145 |
|
try { |
146 |
|
Runnable task = new CheckedRunnable() { |
147 |
|
public void realRun() { |
148 |
|
done.countDown(); |
149 |
< |
assertTrue(System.nanoTime() - t0 >= timeoutNanos); |
149 |
> |
assertTrue(millisElapsedSince(startTime) >= timeoutMillis()); |
150 |
|
}}; |
151 |
|
ScheduledFuture f = |
152 |
< |
p.scheduleAtFixedRate(task, SHORT_DELAY_MS, |
153 |
< |
SHORT_DELAY_MS, MILLISECONDS); |
154 |
< |
assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); |
155 |
< |
assertTrue(System.nanoTime() - t0 >= timeoutNanos); |
152 |
> |
p.scheduleAtFixedRate(task, timeoutMillis(), |
153 |
> |
LONG_DELAY_MS, MILLISECONDS); |
154 |
> |
await(done); |
155 |
> |
assertTrue(millisElapsedSince(startTime) >= timeoutMillis()); |
156 |
|
f.cancel(true); |
157 |
|
} finally { |
158 |
|
joinPool(p); |
164 |
|
*/ |
165 |
|
public void testSchedule5() throws InterruptedException { |
166 |
|
CustomExecutor p = new CustomExecutor(1); |
167 |
< |
final long t0 = System.nanoTime(); |
171 |
< |
final long timeoutNanos = SHORT_DELAY_MS * 1000L * 1000L; |
167 |
> |
final long startTime = System.nanoTime(); |
168 |
|
final CountDownLatch done = new CountDownLatch(1); |
169 |
|
try { |
170 |
|
Runnable task = new CheckedRunnable() { |
171 |
|
public void realRun() { |
172 |
|
done.countDown(); |
173 |
< |
assertTrue(System.nanoTime() - t0 >= timeoutNanos); |
173 |
> |
assertTrue(millisElapsedSince(startTime) >= timeoutMillis()); |
174 |
|
}}; |
175 |
|
ScheduledFuture f = |
176 |
< |
p.scheduleWithFixedDelay(task, SHORT_DELAY_MS, |
177 |
< |
SHORT_DELAY_MS, MILLISECONDS); |
178 |
< |
assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); |
179 |
< |
assertTrue(System.nanoTime() - t0 >= timeoutNanos); |
176 |
> |
p.scheduleWithFixedDelay(task, timeoutMillis(), |
177 |
> |
LONG_DELAY_MS, MILLISECONDS); |
178 |
> |
await(done); |
179 |
> |
assertTrue(millisElapsedSince(startTime) >= timeoutMillis()); |
180 |
|
f.cancel(true); |
181 |
|
} finally { |
182 |
|
joinPool(p); |
374 |
|
assertEquals(0, p.getCompletedTaskCount()); |
375 |
|
threadProceed.countDown(); |
376 |
|
threadDone.await(); |
377 |
< |
delay(SHORT_DELAY_MS); |
378 |
< |
assertEquals(1, p.getCompletedTaskCount()); |
377 |
> |
long startTime = System.nanoTime(); |
378 |
> |
while (p.getCompletedTaskCount() != 1) { |
379 |
> |
if (millisElapsedSince(startTime) > LONG_DELAY_MS) |
380 |
> |
fail("timed out"); |
381 |
> |
Thread.yield(); |
382 |
> |
} |
383 |
|
} finally { |
384 |
|
joinPool(p); |
385 |
|
} |