ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/ThreadPoolExecutorSubclassTest.java
(Generate patch)

Comparing jsr166/src/test/tck/ThreadPoolExecutorSubclassTest.java (file contents):
Revision 1.104 by jsr166, Fri Sep 6 18:43:35 2019 UTC vs.
Revision 1.105 by dl, Tue Jan 26 13:33:06 2021 UTC

# Line 660 | Line 660 | public class ThreadPoolExecutorSubclassT
660                            q);
661          try (PoolCleaner cleaner = cleaner(p, done)) {
662              final CountDownLatch threadStarted = new CountDownLatch(1);
663 <            FutureTask[] tasks = new FutureTask[5];
663 >            FutureTask[] rtasks = new FutureTask[5];
664 >            @SuppressWarnings("unchecked")
665 >            FutureTask<Boolean>[] tasks = (FutureTask<Boolean>[])rtasks;
666              for (int i = 0; i < tasks.length; i++) {
667                  Callable<Boolean> task = new CheckedCallable<Boolean>() {
668                      public Boolean realCall() throws InterruptedException {
# Line 669 | Line 671 | public class ThreadPoolExecutorSubclassT
671                          await(done);
672                          return Boolean.TRUE;
673                      }};
674 <                tasks[i] = new FutureTask(task);
674 >                tasks[i] = new FutureTask<Boolean>(task);
675                  p.execute(tasks[i]);
676              }
677              await(threadStarted);
# Line 726 | Line 728 | public class ThreadPoolExecutorSubclassT
728                            LONG_DELAY_MS, MILLISECONDS,
729                            q);
730          try (PoolCleaner cleaner = cleaner(p, done)) {
731 <            FutureTask[] tasks = new FutureTask[5];
731 >            FutureTask[] rtasks = new FutureTask[5];
732 >            @SuppressWarnings("unchecked")
733 >            FutureTask<Boolean>[] tasks = (FutureTask<Boolean>[])rtasks;
734              for (int i = 0; i < tasks.length; i++) {
735                  Callable<Boolean> task = new CheckedCallable<Boolean>() {
736                      public Boolean realCall() throws InterruptedException {
# Line 734 | Line 738 | public class ThreadPoolExecutorSubclassT
738                          await(done);
739                          return Boolean.TRUE;
740                      }};
741 <                tasks[i] = new FutureTask(task);
741 >                tasks[i] = new FutureTask<Boolean>(task);
742                  p.execute(tasks[i]);
743              }
744              await(threadStarted);
# Line 1828 | Line 1832 | public class ThreadPoolExecutorSubclassT
1832                      p.invokeAll(tasks, timeout, MILLISECONDS);
1833                  assertEquals(tasks.size(), futures.size());
1834                  assertTrue(millisElapsedSince(startTime) >= timeout);
1835 <                for (Future future : futures)
1835 >                for (Future<?> future : futures)
1836                      assertTrue(future.isDone());
1837                  assertTrue(futures.get(1).isCancelled());
1838                  try {
# Line 1966 | Line 1970 | public class ThreadPoolExecutorSubclassT
1970              }
1971          }
1972      }
1973 <
1973 >    @SuppressWarnings("deprecation")
1974      public void testFinalizeMethodCallsSuperFinalize() {
1975          new CustomTPE(1, 1,
1976                        LONG_DELAY_MS, MILLISECONDS,

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines