ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/SubmissionPublisherTest.java
(Generate patch)

Comparing jsr166/src/test/tck/SubmissionPublisherTest.java (file contents):
Revision 1.25 by jsr166, Mon Dec 11 00:16:40 2017 UTC vs.
Revision 1.30 by jsr166, Mon Dec 16 22:55:54 2019 UTC

# Line 334 | Line 334 | public class SubmissionPublisherTest ext
334          TestSubscriber s = new TestSubscriber();
335          SubmissionPublisher<Integer> p = basicPublisher();
336          s.throwOnCall = true;
337 <        try {
338 <            p.subscribe(s);
339 <        } catch (Exception ok) {}
337 >        p.subscribe(s);
338          s.awaitError();
339          assertEquals(0, s.nexts);
340          assertEquals(1, s.errors);
# Line 404 | Line 402 | public class SubmissionPublisherTest ext
402       */
403      public void testCancel() {
404          SubmissionPublisher<Integer> p =
405 <            new SubmissionPublisher<Integer>(basicExecutor, 4); // must be < 20
405 >            new SubmissionPublisher<>(basicExecutor, 4); // must be < 20
406          TestSubscriber s1 = new TestSubscriber();
407          TestSubscriber s2 = new TestSubscriber();
408          p.subscribe(s1);
# Line 960 | 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 986 | 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 1004 | 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