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

Comparing jsr166/src/test/tck/RecursiveActionTest.java (file contents):
Revision 1.24 by jsr166, Mon Nov 22 20:19:47 2010 UTC vs.
Revision 1.25 by jsr166, Tue Nov 23 06:33:26 2010 UTC

# Line 247 | Line 247 | public class RecursiveActionTest extends
247      }
248  
249      /**
250 <     * join/quietlyJoin of a forked task ignores interrupts
250 >     * join/quietlyJoin of a forked task succeeds in the presence of interrupts
251       */
252      public void testJoinIgnoresInterrupts() {
253          RecursiveAction a = new CheckedRecursiveAction() {
# Line 258 | Line 258 | public class RecursiveActionTest extends
258                  assertSame(f, f.fork());
259                  Thread.currentThread().interrupt();
260                  assertNull(f.join());
261 <                assertTrue(Thread.interrupted());
261 >                Thread.interrupted();
262                  assertEquals(21, f.result);
263                  checkCompletedNormally(f);
264  
# Line 270 | Line 270 | public class RecursiveActionTest extends
270                      f.join();
271                      shouldThrow();
272                  } catch (CancellationException success) {
273 <                    assertTrue(Thread.interrupted());
273 >                    Thread.interrupted();
274                      checkCancelled(f);
275                  }
276  
# Line 282 | Line 282 | public class RecursiveActionTest extends
282                      f.join();
283                      shouldThrow();
284                  } catch (FJException success) {
285 <                    assertTrue(Thread.interrupted());
285 >                    Thread.interrupted();
286                      checkCompletedAbnormally(f, success);
287                  }
288  
# Line 291 | Line 291 | public class RecursiveActionTest extends
291                  assertSame(f, f.fork());
292                  Thread.currentThread().interrupt();
293                  f.quietlyJoin();
294 <                assertTrue(Thread.interrupted());
294 >                Thread.interrupted();
295                  assertEquals(21, f.result);
296                  checkCompletedNormally(f);
297  
# Line 300 | Line 300 | public class RecursiveActionTest extends
300                  assertSame(f, f.fork());
301                  Thread.currentThread().interrupt();
302                  f.quietlyJoin();
303 <                assertTrue(Thread.interrupted());
303 >                Thread.interrupted();
304                  checkCancelled(f);
305  
306                  f.reinitialize();
# Line 308 | Line 308 | public class RecursiveActionTest extends
308                  assertSame(f, f.fork());
309                  Thread.currentThread().interrupt();
310                  f.quietlyJoin();
311 <                assertTrue(Thread.interrupted());
311 >                Thread.interrupted();
312                  checkCompletedAbnormally(f, f.getException());
313              }};
314          testInvokeOnPool(mainPool(), a);

Diff Legend

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