Cosmetics

winterbe · winterbe · commit d3dda84ed7b4 · 2015-05-05T08:01:51.000+02:00
diff --git a/src/com/winterbe/java8/samples/concurrent/Atomic1.java b/src/com/winterbe/java8/samples/concurrent/Atomic1.java
@@ -11,7 +11,7 @@
  */
 public class Atomic1 {
 
-    private static final int NUM_INCREMENTS = 10000;
+    private static final int NUM_INCREMENTS = 1000;
 
     private static AtomicInteger atomicInt = new AtomicInteger(0);
 
diff --git a/src/com/winterbe/java8/samples/concurrent/LongAccumulator1.java b/src/com/winterbe/java8/samples/concurrent/LongAccumulator1.java
@@ -3,25 +3,25 @@
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.atomic.LongAccumulator;
+import java.util.function.LongBinaryOperator;
 import java.util.stream.IntStream;
 
 /**
  * @author Benjamin Winterberg
  */
 public class LongAccumulator1 {
 
-    private static final int SIZE = 10;
-
-    private static LongAccumulator accumulator = new LongAccumulator((x, y) -> 2 * x + y, 1L);
-
     public static void main(String[] args) {
         testAccumulate();
     }
 
     private static void testAccumulate() {
+        LongBinaryOperator op = (x, y) -> 2 * x + y;
+        LongAccumulator accumulator = new LongAccumulator(op, 1L);
+
         ExecutorService executor = Executors.newFixedThreadPool(2);
 
-        IntStream.range(0, SIZE)
+        IntStream.range(0, 10)
                 .forEach(i -> executor.submit(() -> accumulator.accumulate(i)));
 
         ConcurrentUtils.stop(executor);
