317 |
|
} |
318 |
|
catch (Throwable ex) { |
319 |
|
compareAndSetForkJoinTaskTag(INITIAL_STATE, EXCEPTION_STATE); |
320 |
+ |
throw new Error(ex); |
321 |
|
} |
322 |
|
return false; |
323 |
|
} |
1164 |
|
final ForkJoinTask b = ForkJoinTask.adapt(awaiter(done)); |
1165 |
|
final ForkJoinTask c = ForkJoinTask.adapt(awaiter(done)); |
1166 |
|
final ForkJoinPool p = singletonPool(); |
1167 |
< |
try (PoolCleaner cleaner = cleaner(p)) { |
1167 |
> |
try (PoolCleaner cleaner = cleaner(p, done)) { |
1168 |
|
Thread external = new Thread(new CheckedRunnable() { |
1169 |
|
public void realRun() { |
1170 |
|
p.execute(a); |
1186 |
|
assertFalse(r.isDone()); |
1187 |
|
}}; |
1188 |
|
p.invoke(s); |
1188 |
– |
done.countDown(); |
1189 |
|
} |
1190 |
|
} |
1191 |
|
|