403 |
|
} |
404 |
|
|
405 |
|
/** |
406 |
– |
* helpQuiesce returns when tasks are complete. |
407 |
– |
* getQueuedTaskCount returns 0 when quiescent |
408 |
– |
*/ |
409 |
– |
public void testForkHelpQuiesce() { |
410 |
– |
RecursiveAction a = new CheckedRecursiveAction() { |
411 |
– |
public void realCompute() { |
412 |
– |
FibAction f = new FibAction(8); |
413 |
– |
assertSame(f, f.fork()); |
414 |
– |
helpQuiesce(); |
415 |
– |
assertEquals(21, f.result); |
416 |
– |
assertEquals(0, getQueuedTaskCount()); |
417 |
– |
checkCompletedNormally(f); |
418 |
– |
}}; |
419 |
– |
checkInvoke(a); |
420 |
– |
} |
421 |
– |
|
422 |
– |
/** |
406 |
|
* invoke task throws exception when task completes abnormally |
407 |
|
*/ |
408 |
|
public void testAbnormalInvoke() { |
1080 |
|
checkCompletedNormally(f); |
1081 |
|
}}; |
1082 |
|
checkInvoke(a); |
1100 |
– |
} |
1101 |
– |
|
1102 |
– |
/** |
1103 |
– |
* helpQuiesce returns when tasks are complete. |
1104 |
– |
* getQueuedTaskCount returns 0 when quiescent |
1105 |
– |
*/ |
1106 |
– |
public void testForkHelpQuiesceCC() { |
1107 |
– |
ForkJoinTask a = new CheckedFJTask() { |
1108 |
– |
public void realCompute() { |
1109 |
– |
CCF f = new LCCF(null, 8); |
1110 |
– |
assertSame(f, f.fork()); |
1111 |
– |
helpQuiesce(); |
1112 |
– |
assertEquals(21, f.number); |
1113 |
– |
assertEquals(0, getQueuedTaskCount()); |
1114 |
– |
checkCompletedNormally(f); |
1115 |
– |
}}; |
1116 |
– |
checkInvoke(a); |
1083 |
|
} |
1084 |
|
|
1085 |
|
/** |