add parallel stream with side effect example

mariofusco · mariofusco · commit b63aceee8684 · 2014-01-26T19:00:49.000+01:00
diff --git a/src/main/java/lambdasinaction/chap6/ParallelStreams.java b/src/main/java/lambdasinaction/chap6/ParallelStreams.java
@@ -27,4 +27,24 @@ public static long rangedSum(long n) {
     public static long parallelRangedSum(long n) {
         return LongStream.rangeClosed(1, n).parallel().reduce(Long::sum).getAsLong();
     }
+
+    public static long sideEffectSum(long n) {
+        Accumulator accumulator = new Accumulator();
+        LongStream.rangeClosed(1, n).forEach(accumulator::add);
+        return accumulator.total;
+    }
+
+    public static long sideEffectParallelSum(long n) {
+        Accumulator accumulator = new Accumulator();
+        LongStream.rangeClosed(1, n).parallel().forEach(accumulator::add);
+        return accumulator.total;
+    }
+
+    public static class Accumulator {
+        private long total = 0;
+
+        public void add(long value) {
+            total += value;
+        }
+    }
 }
diff --git a/src/main/java/lambdasinaction/chap6/ParallelStreamsHarness.java b/src/main/java/lambdasinaction/chap6/ParallelStreamsHarness.java
@@ -14,6 +14,8 @@ public static void main(String[] args) {
         System.out.println("Range forkJoinSum done in: " + measurePerf(ParallelStreams::rangedSum, 10_000_000L) + " msecs");
         System.out.println("Parallel range forkJoinSum done in: " + measurePerf(ParallelStreams::parallelRangedSum, 10_000_000L) + " msecs" );
         System.out.println("ForkJoin sum done in: " + measurePerf(ForkJoinSumCalculator::forkJoinSum, 10_000_000L) + " msecs" );
+        System.out.println("SideEffect sum done in: " + measurePerf(ParallelStreams::sideEffectSum, 10_000_000L) + " msecs" );
+        System.out.println("SideEffect prallel sum done in: " + measurePerf(ParallelStreams::sideEffectParallelSum, 10_000_000L) + " msecs" );
     }
 
     public static <T, R> long measurePerf(Function<T, R> f, T input) {

Original file line number	Diff line number	Diff line change
`@@ -14,6 +14,8 @@ public static void main(String[] args) {`
`14`	`14`	`System.out.println("Range forkJoinSum done in: " + measurePerf(ParallelStreams::rangedSum, 10_000_000L) + " msecs");`
`15`	`15`	`System.out.println("Parallel range forkJoinSum done in: " + measurePerf(ParallelStreams::parallelRangedSum, 10_000_000L) + " msecs" );`
`16`	`16`	`System.out.println("ForkJoin sum done in: " + measurePerf(ForkJoinSumCalculator::forkJoinSum, 10_000_000L) + " msecs" );`
	`17`	`+ System.out.println("SideEffect sum done in: " + measurePerf(ParallelStreams::sideEffectSum, 10_000_000L) + " msecs" );`
	`18`	`+ System.out.println("SideEffect prallel sum done in: " + measurePerf(ParallelStreams::sideEffectParallelSum, 10_000_000L) + " msecs" );`
`17`	`19`	`}`
`18`	`20`
`19`	`21`	`public static <T, R> long measurePerf(Function<T, R> f, T input) {`