ViewVC Help

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

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

Comparing jsr166/src/test/tck/ForkJoinTask8Test.java (file contents):
Revision 1.32 by jsr166, Sun Jul 22 20:42:51 2018 UTC vs.
Revision 1.35 by dl, Tue Jan 26 13:33:06 2021 UTC

#	Line 91 | Line 91 | public class ForkJoinTask8Test extends J
91		}
92		}
93
94	<	void checkNotDone(ForkJoinTask a) {
94	>	void checkNotDone(ForkJoinTask<?> a) {
95		assertFalse(a.isDone());
96		assertFalse(a.isCompletedNormally());
97		assertFalse(a.isCompletedAbnormally());
#	Line 152 | Line 152 | public class ForkJoinTask8Test extends J
152		assertSame(expectedValue, v2);
153		}
154
155	<	void checkCompletedAbnormally(ForkJoinTask a, Throwable t) {
155	>	void checkCompletedAbnormally(ForkJoinTask<?> a, Throwable t) {
156		assertTrue(a.isDone());
157		assertFalse(a.isCancelled());
158		assertFalse(a.isCompletedNormally());
#	Line 532 | Line 532 | public class ForkJoinTask8Test extends J
532		AsyncFib f = new AsyncFib(8);
533		assertSame(f, f.fork());
534		helpQuiesce();
535	+	while (!f.isDone()) // wait out race
536	+	;
537		assertEquals(0, getQueuedTaskCount());
538		f.checkCompletedNormally();
539		}};
#	Line 873 | Line 875 | public class ForkJoinTask8Test extends J
875		RecursiveAction a = new CheckedRecursiveAction() {
876		protected void realCompute() {
877		AsyncFib nul = null;
878	<	Runnable[] throwingActions = {
878	>	assertThrows(
879	>	NullPointerException.class,
880		() -> invokeAll(nul),
881		() -> invokeAll(nul, nul),
882		() -> invokeAll(new AsyncFib(8), new AsyncFib(9), nul),
883		() -> invokeAll(new AsyncFib(8), nul, new AsyncFib(9)),
884	<	() -> invokeAll(nul, new AsyncFib(8), new AsyncFib(9)),
882	<	};
883	<	assertThrows(NullPointerException.class, throwingActions);
884	>	() -> invokeAll(nul, new AsyncFib(8), new AsyncFib(9)));
885		}};
886		testInvokeOnPool(pool, a);
887		}
#	Line 922 | Line 923 | public class ForkJoinTask8Test extends J
923		protected void realCompute() {
924		AsyncFib f = new AsyncFib(8);
925		FailingAsyncFib g = new FailingAsyncFib(9);
926	<	ForkJoinTask[] tasks = { f, g };
926	>	ForkJoinTask<?>[] tasks = { f, g };
927		shuffle(tasks);
928		try {
929		invokeAll(tasks[0], tasks[1]);
#	Line 949 | Line 950 | public class ForkJoinTask8Test extends J
950		AsyncFib f = new AsyncFib(8);
951		FailingAsyncFib g = new FailingAsyncFib(9);
952		AsyncFib h = new AsyncFib(7);
953	<	ForkJoinTask[] tasks = { f, g, h };
953	>	ForkJoinTask<?>[] tasks = { f, g, h };
954		shuffle(tasks);
955		try {
956		invokeAll(tasks[0], tasks[1], tasks[2]);
#	Line 976 | Line 977 | public class ForkJoinTask8Test extends J
977		FailingAsyncFib f = new FailingAsyncFib(8);
978		AsyncFib g = new AsyncFib(9);
979		AsyncFib h = new AsyncFib(7);
980	<	ForkJoinTask[] tasks = { f, g, h };
980	>	ForkJoinTask<?>[] tasks = { f, g, h };
981		shuffle(tasks);
982		try {
983		invokeAll(Arrays.asList(tasks));
#	Line 1171 | Line 1172 | public class ForkJoinTask8Test extends J
1172		*/
1173		public void testPollSubmission() {
1174		final CountDownLatch done = new CountDownLatch(1);
1175	<	final ForkJoinTask a = ForkJoinTask.adapt(awaiter(done));
1176	<	final ForkJoinTask b = ForkJoinTask.adapt(awaiter(done));
1177	<	final ForkJoinTask c = ForkJoinTask.adapt(awaiter(done));
1175	>	final ForkJoinTask<?> a = ForkJoinTask.adapt(awaiter(done));
1176	>	final ForkJoinTask<?> b = ForkJoinTask.adapt(awaiter(done));
1177	>	final ForkJoinTask<?> c = ForkJoinTask.adapt(awaiter(done));
1178		final ForkJoinPool p = singletonPool();
1179		try (PoolCleaner cleaner = cleaner(p, done)) {
1180		Thread external = new Thread(new CheckedRunnable() {
#	Line 1192 | Line 1193 | public class ForkJoinTask8Test extends J
1193		}
1194		assertTrue(p.hasQueuedSubmissions());
1195		assertTrue(Thread.currentThread() instanceof ForkJoinWorkerThread);
1196	<	ForkJoinTask r = ForkJoinTask.pollSubmission();
1196	>	ForkJoinTask<?> r = ForkJoinTask.pollSubmission();
1197		assertTrue(r == a || r == b || r == c);
1198		assertFalse(r.isDone());
1199		}};

Diff Legend

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