Cosmetics

Author: winterbe

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);
 

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);