15 |
|
import java.util.concurrent.ExecutionException; |
16 |
|
import java.util.concurrent.Executor; |
17 |
|
import java.util.concurrent.ExecutorCompletionService; |
18 |
– |
import java.util.concurrent.ExecutorService; |
18 |
|
import java.util.concurrent.Future; |
19 |
|
|
20 |
|
import junit.framework.Test; |
33 |
|
throws InterruptedException, ExecutionException { |
34 |
|
CompletionService<Integer> cs |
35 |
|
= new ExecutorCompletionService<>(e); |
36 |
< |
solvers.forEach((solver) -> cs.submit(solver)); |
36 |
> |
solvers.forEach(cs::submit); |
37 |
|
for (int i = solvers.size(); i > 0; i--) { |
38 |
|
Integer r = cs.take().get(); |
39 |
|
if (r != null) |