412 |
|
p.execute(f); |
413 |
|
assertTrue(p.getPoolSize() >= 4); |
414 |
|
int r = f.get(); |
415 |
< |
assertTrue(r == 832040); |
415 |
> |
assertTrue(r == 832040); |
416 |
|
} finally { |
417 |
|
p.shutdownNow(); // don't wait out shutdown |
418 |
|
} |
630 |
|
final ForkJoinPool p = new ForkJoinPool(1); |
631 |
|
|
632 |
|
Thread t = new Thread(new CheckedInterruptedRunnable() { |
633 |
< |
void realRun() throws Throwable { |
633 |
> |
public void realRun() throws Throwable { |
634 |
|
p.submit(new CheckedCallable<Object>() { |
635 |
|
public Object realCall() throws Throwable { |
636 |
|
try { |