10 |
|
import junit.framework.*; |
11 |
|
import java.util.*; |
12 |
|
import java.util.concurrent.*; |
13 |
+ |
import static java.util.concurrent.TimeUnit.MILLISECONDS; |
14 |
|
import java.math.BigInteger; |
15 |
|
import java.security.*; |
16 |
|
|
36 |
|
public T call() throws Exception { |
37 |
|
Future<T> ftask = exec.submit(func); |
38 |
|
try { |
39 |
< |
return ftask.get(msecs, TimeUnit.MILLISECONDS); |
39 |
> |
return ftask.get(msecs, MILLISECONDS); |
40 |
|
} finally { |
41 |
|
ftask.cancel(true); |
42 |
|
} |
223 |
|
public void testNewSingleThreadScheduledExecutor() throws Exception { |
224 |
|
TrackedCallable callable = new TrackedCallable(); |
225 |
|
ScheduledExecutorService p1 = Executors.newSingleThreadScheduledExecutor(); |
226 |
< |
Future f = p1.schedule(callable, SHORT_DELAY_MS, TimeUnit.MILLISECONDS); |
226 |
> |
Future f = p1.schedule(callable, SHORT_DELAY_MS, MILLISECONDS); |
227 |
|
assertFalse(callable.done); |
228 |
|
Thread.sleep(MEDIUM_DELAY_MS); |
229 |
|
assertTrue(callable.done); |
237 |
|
public void testnewScheduledThreadPool() throws Exception { |
238 |
|
TrackedCallable callable = new TrackedCallable(); |
239 |
|
ScheduledExecutorService p1 = Executors.newScheduledThreadPool(2); |
240 |
< |
Future f = p1.schedule(callable, SHORT_DELAY_MS, TimeUnit.MILLISECONDS); |
240 |
> |
Future f = p1.schedule(callable, SHORT_DELAY_MS, MILLISECONDS); |
241 |
|
assertFalse(callable.done); |
242 |
|
Thread.sleep(MEDIUM_DELAY_MS); |
243 |
|
assertTrue(callable.done); |
251 |
|
public void testunconfigurableScheduledExecutorService() throws Exception { |
252 |
|
TrackedCallable callable = new TrackedCallable(); |
253 |
|
ScheduledExecutorService p1 = Executors.unconfigurableScheduledExecutorService(Executors.newScheduledThreadPool(2)); |
254 |
< |
Future f = p1.schedule(callable, SHORT_DELAY_MS, TimeUnit.MILLISECONDS); |
254 |
> |
Future f = p1.schedule(callable, SHORT_DELAY_MS, MILLISECONDS); |
255 |
|
assertFalse(callable.done); |
256 |
|
Thread.sleep(MEDIUM_DELAY_MS); |
257 |
|
assertTrue(callable.done); |
390 |
|
} finally { |
391 |
|
joinPool(e); |
392 |
|
} |
392 |
– |
|
393 |
|
} |
394 |
|
|
395 |
|
void checkCCL() { |
538 |
|
*/ |
539 |
|
public void testCallable2() throws Exception { |
540 |
|
Callable c = Executors.callable(new NoOpRunnable(), one); |
541 |
< |
assertEquals(one, c.call()); |
541 |
> |
assertSame(one, c.call()); |
542 |
|
} |
543 |
|
|
544 |
|
/** |
547 |
|
public void testCallable3() throws Exception { |
548 |
|
Callable c = Executors.callable(new PrivilegedAction() { |
549 |
|
public Object run() { return one; }}); |
550 |
< |
assertEquals(one, c.call()); |
550 |
> |
assertSame(one, c.call()); |
551 |
|
} |
552 |
|
|
553 |
|
/** |
556 |
|
public void testCallable4() throws Exception { |
557 |
|
Callable c = Executors.callable(new PrivilegedExceptionAction() { |
558 |
|
public Object run() { return one; }}); |
559 |
< |
assertEquals(one, c.call()); |
559 |
> |
assertSame(one, c.call()); |
560 |
|
} |
561 |
|
|
562 |
|
|