--- jsr166/src/test/tck/SubmissionPublisherTest.java 2018/01/07 22:59:18 1.26 +++ jsr166/src/test/tck/SubmissionPublisherTest.java 2018/10/24 21:15:49 1.29 @@ -334,9 +334,7 @@ public class SubmissionPublisherTest ext TestSubscriber s = new TestSubscriber(); SubmissionPublisher p = basicPublisher(); s.throwOnCall = true; - try { - p.subscribe(s); - } catch (Exception ok) {} + p.subscribe(s); s.awaitError(); assertEquals(0, s.nexts); assertEquals(1, s.errors); @@ -986,7 +984,11 @@ public class SubmissionPublisherTest ext */ public void testMissedSignal_8187947() throws Exception { if (!atLeastJava9()) return; // backport to jdk8 too hard - final int N = expensiveTests ? (1 << 20) : (1 << 10); + final int N = + ((ForkJoinPool.getCommonPoolParallelism() < 2) // JDK-8212899 + ? (1 << 5) + : (1 << 10)) + * (expensiveTests ? (1 << 10) : 1); final CountDownLatch finished = new CountDownLatch(1); final SubmissionPublisher pub = new SubmissionPublisher<>(); class Sub implements Subscriber { @@ -1004,7 +1006,9 @@ public class SubmissionPublisherTest ext public void onComplete() {} } pub.subscribe(new Sub()); - CompletableFuture.runAsync(() -> pub.submit(Boolean.TRUE)); + checkTimedGet( + CompletableFuture.runAsync(() -> pub.submit(Boolean.TRUE)), + null); await(finished); } }