ViewVC Help

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

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

Comparing jsr166/src/test/tck/ThreadPoolExecutorSubclassTest.java (file contents):
Revision 1.84 by jsr166, Mon Oct 5 21:42:48 2015 UTC vs.
Revision 1.85 by jsr166, Mon Oct 5 21:54:33 2015 UTC

#	Line 729 | Line 729 | public class ThreadPoolExecutorSubclassT
729		new CustomTPE(1, 1,
730		LONG_DELAY_MS, MILLISECONDS,
731		q);
732	<	try (PoolCleaner cleaner = cleaner(p)) {
732	>	try (PoolCleaner cleaner = cleaner(p, done)) {
733		FutureTask[] tasks = new FutureTask[5];
734		for (int i = 0; i < tasks.length; i++) {
735		Callable task = new CheckedCallable<Boolean>() {
#	Line 741 | Line 741 | public class ThreadPoolExecutorSubclassT
741		tasks[i] = new FutureTask(task);
742		p.execute(tasks[i]);
743		}
744	<	assertTrue(threadStarted.await(MEDIUM_DELAY_MS, MILLISECONDS));
744	>	assertTrue(threadStarted.await(LONG_DELAY_MS, MILLISECONDS));
745		assertEquals(tasks.length, p.getTaskCount());
746		assertEquals(tasks.length - 1, q.size());
747		assertEquals(1L, p.getActiveCount());
#	Line 754 | Line 754 | public class ThreadPoolExecutorSubclassT
754		p.purge();         // Nothing to do
755		assertEquals(tasks.length - 3, q.size());
756		assertEquals(tasks.length - 2, p.getTaskCount());
757	–	done.countDown();
757		}
758		}
759

Diff Legend

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