# | Line 82 | Line 82 | public class FilterDemo { | |
---|---|---|
82 | } | |
83 | int pass = 0; | |
84 | int ps = 2; | |
85 | < | ForkJoinPool fjp = new ForkJoinPool(ps); |
85 | > | ForkJoinPool fjp = new ForkJoinPool(); |
86 | ParallelArray<Rand> pa = ParallelArray.createUsingHandoff(array, fjp); | |
87 | for (;;) { | |
88 | last = System.nanoTime(); | |
# | Line 111 | Line 111 | public class FilterDemo { | |
111 | ps >>>= 1; | |
112 | } | |
113 | // pa.apply(nextRand); | |
114 | < | fjp.setParallelism(ps); |
114 | > | // fjp.setParallelism(ps); |
115 | } | |
116 | fjp.shutdownNow(); | |
117 | fjp.awaitTermination(1, TimeUnit.SECONDS); |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |