ViewVC Help

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

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

Comparing jsr166/src/test/tck/SubmissionPublisherTest.java (file contents):
Revision 1.27 by jsr166, Wed Jun 6 16:24:09 2018 UTC vs.
Revision 1.31 by dl, Tue Jan 26 13:33:06 2021 UTC

#	Line 655 | Line 655 | public class SubmissionPublisherTest ext
655		return false;
656		}
657
658	<	static boolean reqHandle(AtomicInteger count, Subscriber s) {
658	>	static boolean reqHandle(AtomicInteger count, Subscriber<?> s) {
659		count.getAndIncrement();
660		((TestSubscriber)s).sn.request(Long.MAX_VALUE);
661		return true;
#	Line 958 | Line 958 | public class SubmissionPublisherTest ext
958		public void testConsumeNPE() {
959		SubmissionPublisher<Integer> p = basicPublisher();
960		try {
961	<	CompletableFuture<Void> f = p.consume(null);
961	>	CompletableFuture<Void> unused = p.consume(null);
962		shouldThrow();
963		} catch (NullPointerException success) {}
964		}
#	Line 984 | Line 984 | public class SubmissionPublisherTest ext
984		*/
985		public void testMissedSignal_8187947() throws Exception {
986		if (!atLeastJava9()) return; // backport to jdk8 too hard
987	<	final int N = expensiveTests ? (1 << 20) : (1 << 10);
987	>	final int N =
988	>	((ForkJoinPool.getCommonPoolParallelism() < 2) // JDK-8212899
989	>	? (1 << 5)
990	>	: (1 << 10))
991	>	* (expensiveTests ? (1 << 10) : 1);
992		final CountDownLatch finished = new CountDownLatch(1);
993		final SubmissionPublisher<Boolean> pub = new SubmissionPublisher<>();
994		class Sub implements Subscriber<Boolean> {
#	Line 1002 | Line 1006 | public class SubmissionPublisherTest ext
1006		public void onComplete() {}
1007		}
1008		pub.subscribe(new Sub());
1009	<	CompletableFuture.runAsync(() -> pub.submit(Boolean.TRUE));
1009	>	checkTimedGet(
1010	>	CompletableFuture.runAsync(() -> pub.submit(Boolean.TRUE)),
1011	>	null);
1012		await(finished);
1013		}
1014		}

Diff Legend

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