1462 |
|
} |
1463 |
|
|
1464 |
|
/** |
1465 |
< |
* invokeAll(collection) throws exception if any task does |
1465 |
> |
* invokeAll(collection) throws exception if any task does |
1466 |
|
*/ |
1467 |
|
public void testAbnormalInvokeAllCollectionCC() { |
1468 |
|
ForkJoinTask a = new CheckedRecursiveAction() { |
1484 |
|
checkInvoke(a); |
1485 |
|
} |
1486 |
|
|
1487 |
– |
|
1487 |
|
/** |
1488 |
|
* awaitQuiescent by a worker is equivalent in effect to |
1489 |
|
* ForkJoinTask.helpQuiesce() |
1490 |
< |
*/ |
1490 |
> |
*/ |
1491 |
|
public void testAwaitQuiescent1() throws Exception { |
1492 |
|
final ForkJoinPool p = new ForkJoinPool(); |
1493 |
|
try { |
1512 |
|
assertEquals(0, ForkJoinTask.getQueuedTaskCount()); |
1513 |
|
try { |
1514 |
|
assertEquals(21, f.result); |
1515 |
< |
} catch (Throwable fail) { |
1516 |
< |
threadFail(fail.getMessage()); |
1515 |
> |
} catch (Throwable fail) { |
1516 |
> |
threadFail(fail.getMessage()); |
1517 |
|
} |
1518 |
|
} |
1519 |
|
}; |
1540 |
|
joinPool(p); |
1541 |
|
} |
1542 |
|
} |
1543 |
< |
|
1543 |
> |
|
1544 |
|
/** |
1545 |
|
* awaitQuiescent returns when pool isQuiescent() or the indicated |
1546 |
|
* timeout elapse |
1547 |
< |
*/ |
1547 |
> |
*/ |
1548 |
|
public void testAwaitQuiescent2() throws Exception { |
1549 |
|
final ForkJoinPool p = new ForkJoinPool(); |
1550 |
|
try { |
1596 |
|
} |
1597 |
|
} |
1598 |
|
|
1600 |
– |
|
1599 |
|
} |