ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/test/tck/ForkJoinPool8Test.java

Comparing jsr166/src/test/tck/ForkJoinPool8Test.java (file contents):
Revision 1.25 by jsr166, Tue Sep 24 16:16:46 2013 UTC vs.
Revision 1.26 by jsr166, Sat Nov 1 16:02:23 2014 UTC

#	Line 1544 | Line 1544 | public class ForkJoinPool8Test extends J
1544		final ForkJoinPool p = new ForkJoinPool();
1545		try {
1546		assertTrue(p.isQuiescent());
1547	<	for (;;) {
1548	<	final long startTime = System.nanoTime();
1549	<	ForkJoinTask a = new CheckedRecursiveAction() {
1550	<	protected void realCompute() {
1551	<	FibAction f = new FibAction(8);
1552	<	assertSame(f, f.fork());
1553	<	while (!f.isDone()) {
1554	<	assertFalse(p.getAsyncMode());
1555	<	assertFalse(p.isShutdown());
1556	<	assertFalse(p.isTerminating());
1557	<	assertFalse(p.isTerminated());
1558	<	Thread.yield();
1559	<	}
1560	<	assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1561	<	assertEquals(0, ForkJoinTask.getQueuedTaskCount());
1562	<	assertEquals(21, f.result);
1563	<	}};
1564	<	p.execute(a);
1565	<	assertTrue(p.awaitQuiescence(LONG_DELAY_MS, MILLISECONDS));
1566	<	assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1567	<	assertTrue(p.isQuiescent());
1568	<	assertTrue(a.isDone());
1569	<	assertEquals(0, p.getQueuedTaskCount());
1570	<	assertFalse(p.getAsyncMode());
1571	<	assertEquals(0, p.getActiveThreadCount());
1572	<	assertEquals(0, p.getQueuedTaskCount());
1573	<	assertEquals(0, p.getQueuedSubmissionCount());
1574	<	assertFalse(p.hasQueuedSubmissions());
1575	<	assertFalse(p.isShutdown());
1576	<	assertFalse(p.isTerminating());
1577	<	assertFalse(p.isTerminated());
1578	<	break;
1579	<	}
1547	>	final long startTime = System.nanoTime();
1548	>	ForkJoinTask a = new CheckedRecursiveAction() {
1549	>	protected void realCompute() {
1550	>	FibAction f = new FibAction(8);
1551	>	assertSame(f, f.fork());
1552	>	while (!f.isDone()
1553	>	&& millisElapsedSince(startTime) < LONG_DELAY_MS) {
1554	>	assertFalse(p.getAsyncMode());
1555	>	assertFalse(p.isShutdown());
1556	>	assertFalse(p.isTerminating());
1557	>	assertFalse(p.isTerminated());
1558	>	Thread.yield();
1559	>	}
1560	>	assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1561	>	assertEquals(0, ForkJoinTask.getQueuedTaskCount());
1562	>	assertEquals(21, f.result);
1563	>	}};
1564	>	p.execute(a);
1565	>	assertTrue(p.awaitQuiescence(LONG_DELAY_MS, MILLISECONDS));
1566	>	assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
1567	>	assertTrue(p.isQuiescent());
1568	>	assertTrue(a.isDone());
1569	>	assertEquals(0, p.getQueuedTaskCount());
1570	>	assertFalse(p.getAsyncMode());
1571	>	assertEquals(0, p.getActiveThreadCount());
1572	>	assertEquals(0, p.getQueuedTaskCount());
1573	>	assertEquals(0, p.getQueuedSubmissionCount());
1574	>	assertFalse(p.hasQueuedSubmissions());
1575	>	assertFalse(p.isShutdown());
1576	>	assertFalse(p.isTerminating());
1577	>	assertFalse(p.isTerminated());
1578		} finally {
1579		joinPool(p);
1580		}

Diff Legend

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