242 |
|
eh, false); |
243 |
|
try { |
244 |
|
assertSame(eh, p.getUncaughtExceptionHandler()); |
245 |
< |
p.execute(new FibTask(8)); |
246 |
< |
assertTrue(uehInvoked.await(MEDIUM_DELAY_MS, MILLISECONDS)); |
245 |
> |
try { |
246 |
> |
p.execute(new FibTask(8)); |
247 |
> |
assertTrue(uehInvoked.await(10000, MILLISECONDS)); |
248 |
> |
} catch(RejectedExecutionException ok) { |
249 |
> |
} |
250 |
|
} finally { |
251 |
|
p.shutdownNow(); // failure might have prevented processing task |
252 |
|
joinPool(p); |
259 |
|
* the task has completed successfully, and construction |
260 |
|
* parameters continue to hold |
261 |
|
*/ |
262 |
< |
public void testisQuiescent() throws Exception { |
262 |
> |
public void testIsQuiescent() throws Exception { |
263 |
|
ForkJoinPool p = new ForkJoinPool(2); |
264 |
|
try { |
265 |
|
assertTrue(p.isQuiescent()); |