1520 |
|
assertFalse(p.isTerminated()); |
1521 |
|
Thread.yield(); |
1522 |
|
} |
1523 |
– |
assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); |
1523 |
|
assertEquals(0, p.getQueuedTaskCount()); |
1524 |
|
assertFalse(p.getAsyncMode()); |
1526 |
– |
assertEquals(0, p.getActiveThreadCount()); |
1527 |
– |
assertEquals(0, p.getQueuedTaskCount()); |
1525 |
|
assertEquals(0, p.getQueuedSubmissionCount()); |
1526 |
|
assertFalse(p.hasQueuedSubmissions()); |
1527 |
+ |
while (p.getActiveThreadCount() != 0 |
1528 |
+ |
&& millisElapsedSince(startTime) < LONG_DELAY_MS) |
1529 |
+ |
Thread.yield(); |
1530 |
|
assertFalse(p.isShutdown()); |
1531 |
|
assertFalse(p.isTerminating()); |
1532 |
|
assertFalse(p.isTerminated()); |
1533 |
+ |
assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); |
1534 |
|
} |
1535 |
|
} |
1536 |
|
|
1569 |
|
}}; |
1570 |
|
p.execute(a); |
1571 |
|
assertTrue(p.awaitQuiescence(LONG_DELAY_MS, MILLISECONDS)); |
1571 |
– |
assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); |
1572 |
|
assertTrue(p.isQuiescent()); |
1573 |
|
assertTrue(a.isDone()); |
1574 |
|
assertEquals(0, p.getQueuedTaskCount()); |
1575 |
|
assertFalse(p.getAsyncMode()); |
1576 |
– |
assertEquals(0, p.getActiveThreadCount()); |
1577 |
– |
assertEquals(0, p.getQueuedTaskCount()); |
1576 |
|
assertEquals(0, p.getQueuedSubmissionCount()); |
1577 |
|
assertFalse(p.hasQueuedSubmissions()); |
1578 |
+ |
while (p.getActiveThreadCount() != 0 |
1579 |
+ |
&& millisElapsedSince(startTime) < LONG_DELAY_MS) |
1580 |
+ |
Thread.yield(); |
1581 |
|
assertFalse(p.isShutdown()); |
1582 |
|
assertFalse(p.isTerminating()); |
1583 |
|
assertFalse(p.isTerminated()); |
1584 |
+ |
assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); |
1585 |
|
} |
1586 |
|
} |
1587 |
|
|