--- jsr166/src/test/tck/ExecutorCompletionServiceTest.java 2015/10/04 18:28:51 1.22 +++ jsr166/src/test/tck/ExecutorCompletionServiceTest.java 2016/05/03 23:06:12 1.23 @@ -10,6 +10,7 @@ import static java.util.concurrent.TimeU import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.Callable; +import java.util.concurrent.CompletionService; import java.util.concurrent.ExecutorCompletionService; import java.util.concurrent.Executors; import java.util.concurrent.ExecutorService; @@ -166,8 +167,8 @@ public class ExecutorCompletionServiceTe protected RunnableFuture newTaskFor(Callable c) { return new MyCallableFuture(c); }}; - ExecutorCompletionService ecs = - new ExecutorCompletionService(e); + CompletionService ecs = + new ExecutorCompletionService<>(e); try (PoolCleaner cleaner = cleaner(e)) { assertNull(ecs.poll()); Callable c = new StringTask(); @@ -197,8 +198,8 @@ public class ExecutorCompletionServiceTe protected RunnableFuture newTaskFor(Runnable t, T r) { return new MyRunnableFuture(t, r); }}; - final ExecutorCompletionService ecs = - new ExecutorCompletionService(e); + final CompletionService ecs = + new ExecutorCompletionService<>(e); try (PoolCleaner cleaner = cleaner(e)) { assertNull(ecs.poll()); Runnable r = new NoOpRunnable();