ViewVC Help

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

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

Comparing jsr166/src/test/tck/ExecutorCompletionService9Test.java (file contents):
Revision 1.1 by jsr166, Sun May 22 01:09:21 2016 UTC vs.
Revision 1.4 by jsr166, Mon May 23 22:58:06 2016 UTC

#	Line 5 | Line 5
5		* http://creativecommons.org/publicdomain/zero/1.0/
6		*/
7
8	–	import static java.util.concurrent.TimeUnit.MILLISECONDS;
9	–
8		import java.util.ArrayList;
9		import java.util.Collection;
10		import java.util.List;
#	Line 15 | Line 13 | import java.util.HashSet;
13		import java.util.concurrent.Callable;
14		import java.util.concurrent.CompletionService;
15		import java.util.concurrent.ExecutionException;
18	–	import java.util.concurrent.ExecutorCompletionService;
16		import java.util.concurrent.Executor;
17	+	import java.util.concurrent.ExecutorCompletionService;
18		import java.util.concurrent.ExecutorService;
21	–	import java.util.concurrent.ForkJoinPool;
19		import java.util.concurrent.Future;
20
21		import junit.framework.Test;
#	Line 37 | Line 34 | public class ExecutorCompletionService9T
34		throws InterruptedException, ExecutionException {
35		CompletionService<Integer> cs
36		= new ExecutorCompletionService<>(e);
37	<	solvers.forEach((solver) -> cs.submit(solver));
37	>	solvers.forEach(cs::submit);
38		for (int i = solvers.size(); i > 0; i--) {
39		Integer r = cs.take().get();
40		if (r != null)
#	Line 90 | Line 87 | public class ExecutorCompletionService9T
87		() -> 2,
88		() -> 3,
89		() -> null);
90	<	solveAll(ForkJoinPool.commonPool(), solvers);
90	>	solveAll(cachedThreadPool, solvers);
91		assertEquals(Set.of(1, 2, 3), results);
92		}
93	<
93	>
94		/**
95		* The second "solvers" sample code in the class javadoc works.
96		*/
#	Line 104 | Line 101 | public class ExecutorCompletionService9T
101		() -> null,
102		() -> 1,
103		() -> 2);
104	<	solveAny(ForkJoinPool.commonPool(), solvers);
104	>	solveAny(cachedThreadPool, solvers);
105		assertEquals(1, results.size());
106		Integer elt = results.iterator().next();
107		assertTrue(elt.equals(1) || elt.equals(2));

Diff Legend

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