fix parallel stream harness

mariofusco · mariofusco · commit b2338a46e2c6 · 2014-05-07T12:07:35.000+02:00
diff --git a/src/main/java/lambdasinaction/chap6/ParallelStreams.java b/src/main/java/lambdasinaction/chap6/ParallelStreams.java
@@ -6,7 +6,7 @@ public class ParallelStreams {
 
     public static long iterativeSum(long n) {
         long result = 0;
-        for (long i = 0; i < n; i++) {
+        for (long i = 0; i <= n; i++) {
             result += i;
         }
         return result;
diff --git a/src/main/java/lambdasinaction/chap6/ParallelStreamsHarness.java b/src/main/java/lambdasinaction/chap6/ParallelStreamsHarness.java
@@ -8,7 +8,7 @@ public class ParallelStreamsHarness {
     public static final ForkJoinPool FORK_JOIN_POOL = new ForkJoinPool();
 
     public static void main(String[] args) {
-        System.out.println("Iterative Sum done in: " + measurePerf(ParallelStreams::sequentialSum, 10_000_000L) + " msecs");
+        System.out.println("Iterative Sum done in: " + measurePerf(ParallelStreams::iterativeSum, 10_000_000L) + " msecs");
         System.out.println("Sequential Sum done in: " + measurePerf(ParallelStreams::sequentialSum, 10_000_000L) + " msecs");
         System.out.println("Parallel forkJoinSum done in: " + measurePerf(ParallelStreams::parallelSum, 10_000_000L) + " msecs" );
         System.out.println("Range forkJoinSum done in: " + measurePerf(ParallelStreams::rangedSum, 10_000_000L) + " msecs");

Original file line number	Diff line number	Diff line change
`@@ -6,7 +6,7 @@ public class ParallelStreams {`
`6`	`6`
`7`	`7`	`public static long iterativeSum(long n) {`
`8`	`8`	`long result = 0;`
`9`		`- for (long i = 0; i < n; i++) {`
	`9`	`+ for (long i = 0; i <= n; i++) {`
`10`	`10`	`result += i;`
`11`	`11`	`}`
`12`	`12`	`return result;`