10 |
|
|
11 |
|
import java.util.concurrent.ArrayBlockingQueue; |
12 |
|
import java.util.concurrent.Callable; |
13 |
+ |
import java.util.concurrent.CompletionService; |
14 |
|
import java.util.concurrent.ExecutorCompletionService; |
15 |
|
import java.util.concurrent.Executors; |
16 |
|
import java.util.concurrent.ExecutorService; |
167 |
|
protected <T> RunnableFuture<T> newTaskFor(Callable<T> c) { |
168 |
|
return new MyCallableFuture<T>(c); |
169 |
|
}}; |
170 |
< |
ExecutorCompletionService<String> ecs = |
171 |
< |
new ExecutorCompletionService<String>(e); |
170 |
> |
CompletionService<String> ecs = |
171 |
> |
new ExecutorCompletionService<>(e); |
172 |
|
try (PoolCleaner cleaner = cleaner(e)) { |
173 |
|
assertNull(ecs.poll()); |
174 |
|
Callable<String> c = new StringTask(); |
198 |
|
protected <T> RunnableFuture<T> newTaskFor(Runnable t, T r) { |
199 |
|
return new MyRunnableFuture<T>(t, r); |
200 |
|
}}; |
201 |
< |
final ExecutorCompletionService<String> ecs = |
202 |
< |
new ExecutorCompletionService<String>(e); |
201 |
> |
final CompletionService<String> ecs = |
202 |
> |
new ExecutorCompletionService<>(e); |
203 |
|
try (PoolCleaner cleaner = cleaner(e)) { |
204 |
|
assertNull(ecs.poll()); |
205 |
|
Runnable r = new NoOpRunnable(); |