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.22 by jsr166, Tue Sep 17 02:17:11 2013 UTC vs.
Revision 1.23 by jsr166, Sun Sep 22 01:42:44 2013 UTC

# Line 1502 | Line 1502 | public class ForkJoinPool8Test extends J
1502                      assertTrue(quiescent);
1503                      assertFalse(p.isQuiescent());
1504                      while (!f.isDone()) {
1505 –                        assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1505                          assertFalse(p.getAsyncMode());
1506                          assertFalse(p.isShutdown());
1507                          assertFalse(p.isTerminating());
1508                          assertFalse(p.isTerminated());
1509                          Thread.yield();
1510                      }
1511 +                    assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1512                      assertFalse(p.isQuiescent());
1513                      assertEquals(0, ForkJoinTask.getQueuedTaskCount());
1514                      assertEquals(21, f.result);
1515                  }};
1516              p.execute(a);
1517              while (!a.isDone() || !p.isQuiescent()) {
1518 –                assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1518                  assertFalse(p.getAsyncMode());
1519                  assertFalse(p.isShutdown());
1520                  assertFalse(p.isTerminating());
1521                  assertFalse(p.isTerminated());
1522                  Thread.yield();
1523              }
1524 +            assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1525              assertEquals(0, p.getQueuedTaskCount());
1526              assertFalse(p.getAsyncMode());
1527              assertEquals(0, p.getActiveThreadCount());
# Line 1552 | Line 1552 | public class ForkJoinPool8Test extends J
1552                          assertSame(f, f.fork());
1553                          ForkJoinTask.helpQuiesce();
1554                          while (!f.isDone()) {
1555 –                            assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1555                              assertFalse(p.getAsyncMode());
1556                              assertFalse(p.isShutdown());
1557                              assertFalse(p.isTerminating());
1558                              assertFalse(p.isTerminated());
1559                              Thread.yield();
1560                          }
1561 +                        assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1562                          assertEquals(0, ForkJoinTask.getQueuedTaskCount());
1563                          assertEquals(21, f.result);
1564                      }};
# Line 1566 | Line 1566 | public class ForkJoinPool8Test extends J
1566                  if (a.isDone() || p.isQuiescent())
1567                      continue; // Already done so cannot test; retry
1568                  while (!p.awaitQuiescence(LONG_DELAY_MS, MILLISECONDS)) {
1569 –                    assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1569                      assertFalse(p.getAsyncMode());
1570                      assertFalse(p.isShutdown());
1571                      assertFalse(p.isTerminating());
1572                      assertFalse(p.isTerminated());
1573                      Thread.yield();
1574                  }
1575 +                assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1576                  assertTrue(p.isQuiescent());
1577                  assertTrue(a.isDone());
1578                  assertEquals(0, p.getQueuedTaskCount());

Diff Legend

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