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

Comparing jsr166/src/test/tck/ForkJoinPool8Test.java (file contents):
Revision 1.33 by jsr166, Tue Aug 16 23:02:57 2016 UTC vs.
Revision 1.35 by jsr166, Sat Mar 18 18:20:00 2017 UTC

# Line 179 | Line 179 | public class ForkJoinPool8Test extends J
179          public FJException(Throwable cause) { super(cause); }
180      }
181  
182 <    // A simple recursive action for testing
182 >    /** A simple recursive action for testing. */
183      final class FibAction extends CheckedRecursiveAction {
184          final int number;
185          int result;
# Line 197 | Line 197 | public class ForkJoinPool8Test extends J
197          }
198      }
199  
200 <    // A recursive action failing in base case
200 >    /** A recursive action failing in base case. */
201      static final class FailingFibAction extends RecursiveAction {
202          final int number;
203          int result;
# Line 274 | Line 274 | public class ForkJoinPool8Test extends J
274                  // test join()
275                  assertSame(f, f.fork());
276                  currentThread.interrupt();
277 –                assertTrue(currentThread.isInterrupted());
277                  assertNull(f.join());
278                  Thread.interrupted();
279                  assertEquals(21, f.result);
# Line 284 | Line 283 | public class ForkJoinPool8Test extends J
283                  f.cancel(true);
284                  assertSame(f, f.fork());
285                  currentThread.interrupt();
287 –                assertTrue(currentThread.isInterrupted());
286                  try {
287                      f.join();
288                      shouldThrow();
# Line 297 | Line 295 | public class ForkJoinPool8Test extends J
295                  f.completeExceptionally(new FJException());
296                  assertSame(f, f.fork());
297                  currentThread.interrupt();
300 –                assertTrue(currentThread.isInterrupted());
298                  try {
299                      f.join();
300                      shouldThrow();
# Line 310 | Line 307 | public class ForkJoinPool8Test extends J
307                  f = new FibAction(8);
308                  assertSame(f, f.fork());
309                  currentThread.interrupt();
313 –                assertTrue(currentThread.isInterrupted());
310                  f.quietlyJoin();
311                  Thread.interrupted();
312                  assertEquals(21, f.result);
# Line 320 | Line 316 | public class ForkJoinPool8Test extends J
316                  f.cancel(true);
317                  assertSame(f, f.fork());
318                  currentThread.interrupt();
323 –                assertTrue(currentThread.isInterrupted());
319                  f.quietlyJoin();
320                  Thread.interrupted();
321                  checkCancelled(f);
# Line 329 | Line 324 | public class ForkJoinPool8Test extends J
324                  f.completeExceptionally(new FJException());
325                  assertSame(f, f.fork());
326                  currentThread.interrupt();
332 –                assertTrue(currentThread.isInterrupted());
327                  f.quietlyJoin();
328                  Thread.interrupted();
329                  checkCompletedAbnormally(f, f.getException());
# Line 911 | Line 905 | public class ForkJoinPool8Test extends J
905          }
906      }
907  
908 <    // Version of CCF with forced failure in left completions
908 >    /** Version of CCF with forced failure in left completions. */
909      abstract static class FailingCCF extends CountedCompleter {
910          int number;
911          int rnumber;

Diff Legend

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