117 |
|
int ntasks = tasks.size(); |
118 |
|
if (ntasks == 0) |
119 |
|
throw new IllegalArgumentException(); |
120 |
< |
ArrayList<Future<T>> futures = new ArrayList<Future<T>>(ntasks); |
120 |
> |
ArrayList<Future<T>> futures = new ArrayList<>(ntasks); |
121 |
|
ExecutorCompletionService<T> ecs = |
122 |
|
new ExecutorCompletionService<T>(this); |
123 |
|
|
200 |
|
throws InterruptedException { |
201 |
|
if (tasks == null) |
202 |
|
throw new NullPointerException(); |
203 |
< |
ArrayList<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); |
203 |
> |
ArrayList<Future<T>> futures = new ArrayList<>(tasks.size()); |
204 |
|
boolean done = false; |
205 |
|
try { |
206 |
|
for (Callable<T> t : tasks) { |
233 |
|
if (tasks == null) |
234 |
|
throw new NullPointerException(); |
235 |
|
long nanos = unit.toNanos(timeout); |
236 |
< |
ArrayList<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); |
236 |
> |
ArrayList<Future<T>> futures = new ArrayList<>(tasks.size()); |
237 |
|
boolean done = false; |
238 |
|
try { |
239 |
|
for (Callable<T> t : tasks) |