499 |
|
AsyncFib f = new AsyncFib(8); |
500 |
|
assertSame(f, f.fork()); |
501 |
|
helpQuiesce(); |
502 |
+ |
while (!f.isDone()) // wait out race |
503 |
+ |
; |
504 |
|
assertEquals(21, f.number); |
505 |
|
assertEquals(0, getQueuedTaskCount()); |
506 |
|
checkCompletedNormally(f); |
1691 |
|
assertEquals( |
1692 |
|
identityString(task) + "[Wrapped task = " + c.toString() + "]", |
1693 |
|
task.toString()); |
1694 |
+ |
} |
1695 |
+ |
} |
1696 |
+ |
|
1697 |
+ |
/** |
1698 |
+ |
* adaptInterruptible(callable).toString() contains toString of wrapped task |
1699 |
+ |
*/ |
1700 |
+ |
public void testAdaptInterruptible_Callable_toString() { |
1701 |
+ |
if (testImplementationDetails) { |
1702 |
+ |
Callable<String> c = () -> ""; |
1703 |
+ |
ForkJoinTask<String> task = ForkJoinTask.adaptInterruptible(c); |
1704 |
+ |
assertEquals( |
1705 |
+ |
identityString(task) + "[Wrapped task = " + c.toString() + "]", |
1706 |
+ |
task.toString()); |
1707 |
|
} |
1708 |
|
} |
1709 |
|
} |