--- jsr166/src/test/tck/ThreadPoolExecutorSubclassTest.java	2019/09/06 18:43:35	1.104
+++ jsr166/src/test/tck/ThreadPoolExecutorSubclassTest.java	2022/03/22 21:29:24	1.107
@@ -660,16 +660,18 @@ public class ThreadPoolExecutorSubclassT
                           q);
         try (PoolCleaner cleaner = cleaner(p, done)) {
             final CountDownLatch threadStarted = new CountDownLatch(1);
-            FutureTask[] tasks = new FutureTask[5];
+            FutureTask[] rtasks = new FutureTask[5];
+            @SuppressWarnings("unchecked")
+            FutureTask<Boolean>[] tasks = (FutureTask<Boolean>[])rtasks;
             for (int i = 0; i < tasks.length; i++) {
-                Callable<Boolean> task = new CheckedCallable<Boolean>() {
+                Callable<Boolean> 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);
@@ -726,15 +728,17 @@ public class ThreadPoolExecutorSubclassT
                           LONG_DELAY_MS, MILLISECONDS,
                           q);
         try (PoolCleaner cleaner = cleaner(p, done)) {
-            FutureTask[] tasks = new FutureTask[5];
+            FutureTask[] rtasks = new FutureTask[5];
+            @SuppressWarnings("unchecked")
+            FutureTask<Boolean>[] tasks = (FutureTask<Boolean>[])rtasks;
             for (int i = 0; i < tasks.length; i++) {
-                Callable<Boolean> task = new CheckedCallable<Boolean>() {
+                Callable<Boolean> 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);
@@ -1809,7 +1813,7 @@ public class ThreadPoolExecutorSubclassT
     public void testTimedInvokeAll6() throws Exception {
         for (long timeout = timeoutMillis();;) {
             final CountDownLatch done = new CountDownLatch(1);
-            final Callable<String> waiter = new CheckedCallable<String>() {
+            final Callable<String> waiter = new CheckedCallable<>() {
                 public String realCall() {
                     try { done.await(LONG_DELAY_MS, MILLISECONDS); }
                     catch (InterruptedException ok) {}
@@ -1828,7 +1832,7 @@ public class ThreadPoolExecutorSubclassT
                     p.invokeAll(tasks, timeout, MILLISECONDS);
                 assertEquals(tasks.size(), futures.size());
                 assertTrue(millisElapsedSince(startTime) >= timeout);
-                for (Future future : futures)
+                for (Future<?> future : futures)
                     assertTrue(future.isDone());
                 assertTrue(futures.get(1).isCancelled());
                 try {
@@ -1966,7 +1970,7 @@ public class ThreadPoolExecutorSubclassT
             }
         }
     }
-
+    @SuppressWarnings("removal")
     public void testFinalizeMethodCallsSuperFinalize() {
         new CustomTPE(1, 1,
                       LONG_DELAY_MS, MILLISECONDS,