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.12 by dl, Sat Sep 12 17:18:13 2015 UTC vs.
Revision 1.15 by jsr166, Sun Nov 6 22:50:32 2016 UTC

#	Line 10 | Line 10 | import java.util.concurrent.Executor;
10		import java.util.concurrent.Executors;
11		import java.util.concurrent.Flow;
12		import java.util.concurrent.ForkJoinPool;
13	–	import java.util.concurrent.LinkedBlockingQueue;
13		import java.util.concurrent.SubmissionPublisher;
15	–	import java.util.concurrent.ThreadFactory;
16	–	import java.util.concurrent.ThreadPoolExecutor;
17	–	import java.util.concurrent.TimeUnit;
14		import java.util.concurrent.atomic.AtomicInteger;
19	–	import java.util.function.BiConsumer;
20	–	import java.util.function.BiFunction;
21	–	import java.util.function.BiPredicate;
22	–	import java.util.stream.Stream;
15		import junit.framework.Test;
16		import junit.framework.TestSuite;
17
26	–	import static java.util.concurrent.Flow.Publisher;
18		import static java.util.concurrent.Flow.Subscriber;
19		import static java.util.concurrent.Flow.Subscription;
20		import static java.util.concurrent.TimeUnit.MILLISECONDS;
30	–	import static java.util.concurrent.TimeUnit.SECONDS;
21
22		public class SubmissionPublisherTest extends JSR166TestCase {
23
#	Line 39 | Line 29 | public class SubmissionPublisherTest ext
29		}
30
31		final Executor basicExecutor = basicPublisher().getExecutor();
32	<
32	>
33		static SubmissionPublisher<Integer> basicPublisher() {
34		return new SubmissionPublisher<Integer>();
35		}
#	Line 946 | Line 936 | public class SubmissionPublisherTest ext
936		AtomicInteger sum = new AtomicInteger();
937		SubmissionPublisher<Integer> p = basicPublisher();
938		CompletableFuture<Void> f =
939	<	p.consume((Integer x) -> { sum.getAndAdd(x.intValue()); });
939	>	p.consume((Integer x) -> sum.getAndAdd(x.intValue()));
940		int n = 20;
941		for (int i = 1; i <= n; ++i)
942		p.submit(i);

Diff Legend

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