| 2685 |
|
// In previous versions of this class, this method constructed |
| 2686 |
|
// a task to run ForkJoinTask.invokeAll, but now external |
| 2687 |
|
// invocation of multiple tasks is at least as efficient. |
| 2688 |
< |
List<ForkJoinTask<T>> fs = new ArrayList<ForkJoinTask<T>>(tasks.size()); |
| 2689 |
< |
// Workaround needed because method wasn't declared with |
| 2690 |
< |
// wildcards in return type but should have been. |
| 2691 |
< |
@SuppressWarnings({"unchecked", "rawtypes"}) |
| 2692 |
< |
List<Future<T>> futures = (List<Future<T>>) (List) fs; |
| 2688 |
> |
ArrayList<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); |
| 2689 |
|
|
| 2690 |
|
boolean done = false; |
| 2691 |
|
try { |
| 2692 |
|
for (Callable<T> t : tasks) { |
| 2693 |
|
ForkJoinTask<T> f = new ForkJoinTask.AdaptedCallable<T>(t); |
| 2694 |
|
externalPush(f); |
| 2695 |
< |
fs.add(f); |
| 2695 |
> |
futures.add(f); |
| 2696 |
|
} |
| 2697 |
< |
for (ForkJoinTask<T> f : fs) |
| 2698 |
< |
f.quietlyJoin(); |
| 2697 |
> |
for (int i = 0, size = futures.size(); i < size; i++) |
| 2698 |
> |
((ForkJoinTask<?>)futures.get(i)).quietlyJoin(); |
| 2699 |
|
done = true; |
| 2700 |
|
return futures; |
| 2701 |
|
} finally { |
| 2702 |
|
if (!done) |
| 2703 |
< |
for (ForkJoinTask<T> f : fs) |
| 2704 |
< |
f.cancel(false); |
| 2703 |
> |
for (int i = 0, size = futures.size(); i < size; i++) |
| 2704 |
> |
futures.get(i).cancel(false); |
| 2705 |
|
} |
| 2706 |
|
} |
| 2707 |
|
|
