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

Comparing jsr166/src/test/tck/ForkJoinTask8Test.java (file contents):
Revision 1.34 by dl, Mon Aug 12 15:08:44 2019 UTC vs.
Revision 1.35 by dl, Tue Jan 26 13:33:06 2021 UTC

# Line 91 | Line 91 | public class ForkJoinTask8Test extends J
91          }
92      }
93  
94 <    void checkNotDone(ForkJoinTask a) {
94 >    void checkNotDone(ForkJoinTask<?> a) {
95          assertFalse(a.isDone());
96          assertFalse(a.isCompletedNormally());
97          assertFalse(a.isCompletedAbnormally());
# Line 152 | Line 152 | public class ForkJoinTask8Test extends J
152          assertSame(expectedValue, v2);
153      }
154  
155 <    void checkCompletedAbnormally(ForkJoinTask a, Throwable t) {
155 >    void checkCompletedAbnormally(ForkJoinTask<?> a, Throwable t) {
156          assertTrue(a.isDone());
157          assertFalse(a.isCancelled());
158          assertFalse(a.isCompletedNormally());
# Line 923 | Line 923 | public class ForkJoinTask8Test extends J
923              protected void realCompute() {
924                  AsyncFib f = new AsyncFib(8);
925                  FailingAsyncFib g = new FailingAsyncFib(9);
926 <                ForkJoinTask[] tasks = { f, g };
926 >                ForkJoinTask<?>[] tasks = { f, g };
927                  shuffle(tasks);
928                  try {
929                      invokeAll(tasks[0], tasks[1]);
# Line 950 | Line 950 | public class ForkJoinTask8Test extends J
950                  AsyncFib f = new AsyncFib(8);
951                  FailingAsyncFib g = new FailingAsyncFib(9);
952                  AsyncFib h = new AsyncFib(7);
953 <                ForkJoinTask[] tasks = { f, g, h };
953 >                ForkJoinTask<?>[] tasks = { f, g, h };
954                  shuffle(tasks);
955                  try {
956                      invokeAll(tasks[0], tasks[1], tasks[2]);
# Line 977 | Line 977 | public class ForkJoinTask8Test extends J
977                  FailingAsyncFib f = new FailingAsyncFib(8);
978                  AsyncFib g = new AsyncFib(9);
979                  AsyncFib h = new AsyncFib(7);
980 <                ForkJoinTask[] tasks = { f, g, h };
980 >                ForkJoinTask<?>[] tasks = { f, g, h };
981                  shuffle(tasks);
982                  try {
983                      invokeAll(Arrays.asList(tasks));
# Line 1172 | Line 1172 | public class ForkJoinTask8Test extends J
1172       */
1173      public void testPollSubmission() {
1174          final CountDownLatch done = new CountDownLatch(1);
1175 <        final ForkJoinTask a = ForkJoinTask.adapt(awaiter(done));
1176 <        final ForkJoinTask b = ForkJoinTask.adapt(awaiter(done));
1177 <        final ForkJoinTask c = ForkJoinTask.adapt(awaiter(done));
1175 >        final ForkJoinTask<?> a = ForkJoinTask.adapt(awaiter(done));
1176 >        final ForkJoinTask<?> b = ForkJoinTask.adapt(awaiter(done));
1177 >        final ForkJoinTask<?> c = ForkJoinTask.adapt(awaiter(done));
1178          final ForkJoinPool p = singletonPool();
1179          try (PoolCleaner cleaner = cleaner(p, done)) {
1180              Thread external = new Thread(new CheckedRunnable() {
# Line 1193 | Line 1193 | public class ForkJoinTask8Test extends J
1193                      }
1194                      assertTrue(p.hasQueuedSubmissions());
1195                      assertTrue(Thread.currentThread() instanceof ForkJoinWorkerThread);
1196 <                    ForkJoinTask r = ForkJoinTask.pollSubmission();
1196 >                    ForkJoinTask<?> r = ForkJoinTask.pollSubmission();
1197                      assertTrue(r == a || r == b || r == c);
1198                      assertFalse(r.isDone());
1199                  }};

Diff Legend

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