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.105 by dl, Tue Jan 26 13:33:06 2021 UTC vs.
Revision 1.106 by jsr166, Wed Jan 27 01:57:24 2021 UTC

#	Line 664 | Line 664 | public class ThreadPoolExecutorSubclassT
664		@SuppressWarnings("unchecked")
665		FutureTask<Boolean>[] tasks = (FutureTask<Boolean>[])rtasks;
666		for (int i = 0; i < tasks.length; i++) {
667	<	Callable<Boolean> task = new CheckedCallable<Boolean>() {
667	>	Callable<Boolean> task = new CheckedCallable<>() {
668		public Boolean realCall() throws InterruptedException {
669		threadStarted.countDown();
670		assertSame(q, p.getQueue());
671		await(done);
672		return Boolean.TRUE;
673		}};
674	<	tasks[i] = new FutureTask<Boolean>(task);
674	>	tasks[i] = new FutureTask<>(task);
675		p.execute(tasks[i]);
676		}
677		await(threadStarted);
#	Line 732 | Line 732 | public class ThreadPoolExecutorSubclassT
732		@SuppressWarnings("unchecked")
733		FutureTask<Boolean>[] tasks = (FutureTask<Boolean>[])rtasks;
734		for (int i = 0; i < tasks.length; i++) {
735	<	Callable<Boolean> task = new CheckedCallable<Boolean>() {
735	>	Callable<Boolean> task = new CheckedCallable<>() {
736		public Boolean realCall() throws InterruptedException {
737		threadStarted.countDown();
738		await(done);
739		return Boolean.TRUE;
740		}};
741	<	tasks[i] = new FutureTask<Boolean>(task);
741	>	tasks[i] = new FutureTask<>(task);
742		p.execute(tasks[i]);
743		}
744		await(threadStarted);
#	Line 1813 | Line 1813 | public class ThreadPoolExecutorSubclassT
1813		public void testTimedInvokeAll6() throws Exception {
1814		for (long timeout = timeoutMillis();;) {
1815		final CountDownLatch done = new CountDownLatch(1);
1816	<	final Callable<String> waiter = new CheckedCallable<String>() {
1816	>	final Callable<String> waiter = new CheckedCallable<>() {
1817		public String realCall() {
1818		try { done.await(LONG_DELAY_MS, MILLISECONDS); }
1819		catch (InterruptedException ok) {}

Diff Legend

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