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.21 by jsr166, Mon Sep 16 01:43:29 2013 UTC vs.
Revision 1.22 by jsr166, Tue Sep 17 02:17:11 2013 UTC

# Line 1497 | Line 1497 | public class ForkJoinPool8Test extends J
1497                  protected void realCompute() {
1498                      FibAction f = new FibAction(8);
1499                      assertSame(f, f.fork());
1500 <                    boolean quiescent = ForkJoinTask.getPool().awaitQuiescence(MEDIUM_DELAY_MS, MILLISECONDS);
1500 >                    assertSame(p, ForkJoinTask.getPool());
1501 >                    boolean quiescent = p.awaitQuiescence(LONG_DELAY_MS, MILLISECONDS);
1502                      assertTrue(quiescent);
1503 +                    assertFalse(p.isQuiescent());
1504                      while (!f.isDone()) {
1505 <                        if (millisElapsedSince(startTime) > LONG_DELAY_MS)
1504 <                            threadFail("timed out");
1505 >                        assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1506                          assertFalse(p.getAsyncMode());
1507                          assertFalse(p.isShutdown());
1508                          assertFalse(p.isTerminating());
# Line 1514 | Line 1515 | public class ForkJoinPool8Test extends J
1515                  }};
1516              p.execute(a);
1517              while (!a.isDone() || !p.isQuiescent()) {
1518 <                if (millisElapsedSince(startTime) > LONG_DELAY_MS)
1518 <                    throw new AssertionFailedError("timed out");
1518 >                assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1519                  assertFalse(p.getAsyncMode());
1520                  assertFalse(p.isShutdown());
1521                  assertFalse(p.isTerminating());
# Line 1552 | Line 1552 | public class ForkJoinPool8Test extends J
1552                          assertSame(f, f.fork());
1553                          ForkJoinTask.helpQuiesce();
1554                          while (!f.isDone()) {
1555 <                            if (millisElapsedSince(startTime) > LONG_DELAY_MS)
1556 <                                threadFail("timed out");
1555 >                            assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1556                              assertFalse(p.getAsyncMode());
1557                              assertFalse(p.isShutdown());
1558                              assertFalse(p.isTerminating());
# Line 1567 | 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 <                    if (millisElapsedSince(startTime) > LONG_DELAY_MS)
1571 <                        threadFail("timed out");
1569 >                    assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1570                      assertFalse(p.getAsyncMode());
1571                      assertFalse(p.isShutdown());
1572                      assertFalse(p.isTerminating());

Diff Legend

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