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.80 by jsr166, Sun Oct 4 02:21:43 2015 UTC vs.
Revision 1.82 by jsr166, Sun Oct 4 02:26:47 2015 UTC

#	Line 402 | Line 402 | public class ThreadPoolExecutorTest exte
402		new ThreadPoolExecutor(1, 1,
403		LONG_DELAY_MS, MILLISECONDS,
404		new ArrayBlockingQueue<Runnable>(10));
405	<	final CountDownLatch threadStarted = new CountDownLatch(1);
406	<	final CountDownLatch done = new CountDownLatch(1);
407	<	try {
405	>	try (PoolCleaner cleaner = cleaner(p)) {
406	>	final CountDownLatch threadStarted = new CountDownLatch(1);
407	>	final CountDownLatch done = new CountDownLatch(1);
408		assertEquals(0, p.getTaskCount());
409		p.execute(new CheckedRunnable() {
410		public void realRun() throws InterruptedException {
#	Line 414 | Line 414 | public class ThreadPoolExecutorTest exte
414		}});
415		assertTrue(threadStarted.await(MEDIUM_DELAY_MS, MILLISECONDS));
416		assertEquals(1, p.getTaskCount());
417	–	} finally {
417		done.countDown();
419	–	joinPool(p);
418		}
419		}
420
#	Line 428 | Line 426 | public class ThreadPoolExecutorTest exte
426		new ThreadPoolExecutor(1, 1,
427		LONG_DELAY_MS, MILLISECONDS,
428		new ArrayBlockingQueue<Runnable>(10));
429	<	assertFalse(p.isShutdown());
430	<	try { p.shutdown(); } catch (SecurityException ok) { return; }
431	<	assertTrue(p.isShutdown());
432	<	joinPool(p);
429	>	try (PoolCleaner cleaner = cleaner(p)) {
430	>	assertFalse(p.isShutdown());
431	>	try { p.shutdown(); } catch (SecurityException ok) { return; }
432	>	assertTrue(p.isShutdown());
433	>	}
434		}
435
436		/**

Diff Legend

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