ViewVC Help

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

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

Comparing jsr166/src/test/tck/ThreadPoolExecutorTest.java (file contents):
Revision 1.86 by jsr166, Sun Oct 4 02:34:48 2015 UTC vs.
Revision 1.89 by jsr166, Sun Oct 4 02:49:18 2015 UTC

#	Line 563 | Line 563 | public class ThreadPoolExecutorTest exte
563		new ThreadPoolExecutor(1, 1,
564		LONG_DELAY_MS, MILLISECONDS,
565		q);
566	<	Runnable[] tasks = new Runnable[5];
567	<	final CountDownLatch threadStarted = new CountDownLatch(1);
568	<	final CountDownLatch done = new CountDownLatch(1);
569	<	try {
566	>	try (PoolCleaner cleaner = cleaner(p)) {
567	>	Runnable[] tasks = new Runnable[6];
568	>	final CountDownLatch threadStarted = new CountDownLatch(1);
569	>	final CountDownLatch done = new CountDownLatch(1);
570		for (int i = 0; i < tasks.length; i++) {
571		tasks[i] = new CheckedRunnable() {
572		public void realRun() throws InterruptedException {
#	Line 585 | Line 585 | public class ThreadPoolExecutorTest exte
585		assertTrue(q.contains(tasks[3]));
586		assertTrue(p.remove(tasks[3]));
587		assertFalse(q.contains(tasks[3]));
588	–	} finally {
588		done.countDown();
590	–	joinPool(p);
589		}
590		}
591
#	Line 602 | Line 600 | public class ThreadPoolExecutorTest exte
600		new ThreadPoolExecutor(1, 1,
601		LONG_DELAY_MS, MILLISECONDS,
602		q);
603	<	FutureTask[] tasks = new FutureTask[5];
604	<	try {
603	>	try (PoolCleaner cleaner = cleaner(p)) {
604	>	FutureTask[] tasks = new FutureTask[5];
605		for (int i = 0; i < tasks.length; i++) {
606		Callable task = new CheckedCallable<Boolean>() {
607		public Boolean realCall() throws InterruptedException {
#	Line 627 | Line 625 | public class ThreadPoolExecutorTest exte
625		p.purge();         // Nothing to do
626		assertEquals(tasks.length - 3, q.size());
627		assertEquals(tasks.length - 2, p.getTaskCount());
630	–	} finally {
628		done.countDown();
632	–	joinPool(p);
629		}
630		}
631
#	Line 1022 | Line 1018 | public class ThreadPoolExecutorTest exte
1018		60, SECONDS,
1019		new ArrayBlockingQueue<Runnable>(10));
1020
1021	<	final CountDownLatch threadStarted = new CountDownLatch(1);
1022	<	final CountDownLatch done = new CountDownLatch(1);
1023	<	try {
1021	>	try (PoolCleaner cleaner = cleaner(p)) {
1022	>	final CountDownLatch threadStarted = new CountDownLatch(1);
1023	>	final CountDownLatch done = new CountDownLatch(1);
1024		Thread t = newStartedThread(new CheckedInterruptedRunnable() {
1025		public void realRun() throws Exception {
1026		Callable task = new CheckedCallable<Boolean>() {
#	Line 1039 | Line 1035 | public class ThreadPoolExecutorTest exte
1035		assertTrue(threadStarted.await(MEDIUM_DELAY_MS, MILLISECONDS));
1036		t.interrupt();
1037		awaitTermination(t, MEDIUM_DELAY_MS);
1042	–	} finally {
1038		done.countDown();
1044	–	joinPool(p);
1039		}
1040		}
1041
#	Line 1049 | Line 1043 | public class ThreadPoolExecutorTest exte
1043		* execute throws RejectedExecutionException if saturated.
1044		*/
1045		public void testSaturatedExecute() {
1046	<	ThreadPoolExecutor p =
1046	>	final ThreadPoolExecutor p =
1047		new ThreadPoolExecutor(1, 1,
1048		LONG_DELAY_MS, MILLISECONDS,
1049		new ArrayBlockingQueue<Runnable>(1));
1050	<	final CountDownLatch done = new CountDownLatch(1);
1051	<	try {
1050	>	try (PoolCleaner cleaner = cleaner(p)) {
1051	>	final CountDownLatch done = new CountDownLatch(1);
1052		Runnable task = new CheckedRunnable() {
1053		public void realRun() throws InterruptedException {
1054		done.await();
#	Line 1068 | Line 1062 | public class ThreadPoolExecutorTest exte
1062		} catch (RejectedExecutionException success) {}
1063		assertTrue(p.getTaskCount() <= 2);
1064		}
1071	–	} finally {
1065		done.countDown();
1073	–	joinPool(p);
1066		}
1067		}
1068

Diff Legend

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