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.2 by jsr166, Sun May 22 15:29:32 2016 UTC vs.
Revision 1.5 by jsr166, Wed Aug 24 22:22:39 2016 UTC

#	Line 13 | Line 13 | import java.util.HashSet;
13		import java.util.concurrent.Callable;
14		import java.util.concurrent.CompletionService;
15		import java.util.concurrent.ExecutionException;
16	–	import java.util.concurrent.ExecutorCompletionService;
16		import java.util.concurrent.Executor;
17	<	import java.util.concurrent.ExecutorService;
19	<	import java.util.concurrent.ForkJoinPool;
17	>	import java.util.concurrent.ExecutorCompletionService;
18		import java.util.concurrent.Future;
19
20		import junit.framework.Test;
#	Line 35 | Line 33 | public class ExecutorCompletionService9T
33		throws InterruptedException, ExecutionException {
34		CompletionService<Integer> cs
35		= new ExecutorCompletionService<>(e);
36	<	solvers.forEach((solver) -> cs.submit(solver));
36	>	solvers.forEach(cs::submit);
37		for (int i = solvers.size(); i > 0; i--) {
38		Integer r = cs.take().get();
39		if (r != null)
#	Line 88 | Line 86 | public class ExecutorCompletionService9T
86		() -> 2,
87		() -> 3,
88		() -> null);
89	<	solveAll(ForkJoinPool.commonPool(), solvers);
89	>	solveAll(cachedThreadPool, solvers);
90		assertEquals(Set.of(1, 2, 3), results);
91		}
92
#	Line 102 | Line 100 | public class ExecutorCompletionService9T
100		() -> null,
101		() -> 1,
102		() -> 2);
103	<	solveAny(ForkJoinPool.commonPool(), solvers);
103	>	solveAny(cachedThreadPool, solvers);
104		assertEquals(1, results.size());
105		Integer elt = results.iterator().next();
106		assertTrue(elt.equals(1) || elt.equals(2));

Diff Legend

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