ViewVC Help

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

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

Comparing jsr166/src/test/tck/JSR166TestCase.java (file contents):
Revision 1.147 by jsr166, Sat Sep 26 19:08:26 2015 UTC vs.
Revision 1.149 by jsr166, Sat Oct 3 16:57:25 2015 UTC

#	Line 743 | Line 743 | public class JSR166TestCase extends Test
743		}
744
745		/**
746	+	* Allows use of try-with-resources with per-test thread pools.
747	+	*/
748	+	static class PoolCloser<T extends ExecutorService>
749	+	implements AutoCloseable {
750	+	public final T pool;
751	+	public PoolCloser(T pool) { this.pool = pool; }
752	+	public void close() { joinPool(pool); }
753	+	}
754	+
755	+	/**
756		* Waits out termination of a thread pool or fails doing so.
757		*/
758	<	void joinPool(ExecutorService pool) {
758	>	static void joinPool(ExecutorService pool) {
759		try {
760		pool.shutdown();
761		if (!pool.awaitTermination(2 * LONG_DELAY_MS, MILLISECONDS))
#	Line 1254 | Line 1264 | public class JSR166TestCase extends Test
1264		}};
1265		}
1266
1267	+	public Runnable countDowner(final CountDownLatch latch) {
1268	+	return new CheckedRunnable() {
1269	+	public void realRun() throws InterruptedException {
1270	+	latch.countDown();
1271	+	}};
1272	+	}
1273	+
1274		public Runnable awaiter(final CountDownLatch latch) {
1275		return new CheckedRunnable() {
1276		public void realRun() throws InterruptedException {

Diff Legend

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