--- jsr166/src/test/tck/ThreadPoolExecutorSubclassTest.java 2021/01/26 13:33:06 1.105 +++ jsr166/src/test/tck/ThreadPoolExecutorSubclassTest.java 2021/01/27 01:57:24 1.106 @@ -664,14 +664,14 @@ public class ThreadPoolExecutorSubclassT @SuppressWarnings("unchecked") FutureTask[] tasks = (FutureTask[])rtasks; for (int i = 0; i < tasks.length; i++) { - Callable task = new CheckedCallable() { + Callable task = new CheckedCallable<>() { public Boolean realCall() throws InterruptedException { threadStarted.countDown(); assertSame(q, p.getQueue()); await(done); return Boolean.TRUE; }}; - tasks[i] = new FutureTask(task); + tasks[i] = new FutureTask<>(task); p.execute(tasks[i]); } await(threadStarted); @@ -732,13 +732,13 @@ public class ThreadPoolExecutorSubclassT @SuppressWarnings("unchecked") FutureTask[] tasks = (FutureTask[])rtasks; for (int i = 0; i < tasks.length; i++) { - Callable task = new CheckedCallable() { + Callable task = new CheckedCallable<>() { public Boolean realCall() throws InterruptedException { threadStarted.countDown(); await(done); return Boolean.TRUE; }}; - tasks[i] = new FutureTask(task); + tasks[i] = new FutureTask<>(task); p.execute(tasks[i]); } await(threadStarted); @@ -1813,7 +1813,7 @@ public class ThreadPoolExecutorSubclassT public void testTimedInvokeAll6() throws Exception { for (long timeout = timeoutMillis();;) { final CountDownLatch done = new CountDownLatch(1); - final Callable waiter = new CheckedCallable() { + final Callable waiter = new CheckedCallable<>() { public String realCall() { try { done.await(LONG_DELAY_MS, MILLISECONDS); } catch (InterruptedException ok) {}