lovejavaee
diff --git a/‎src/com/winterbe/java8/samples/concurrent/Atomic1.java‎
Lines changed: 2 additions & 5 deletions b/‎src/com/winterbe/java8/samples/concurrent/Atomic1.java‎
Lines changed: 2 additions & 5 deletions
@@ -3,7 +3,6 @@
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.atomic.AtomicInteger;
-import java.util.function.IntBinaryOperator;
 import java.util.stream.IntStream;
 
 /**
@@ -45,10 +44,8 @@ private static void testAccumulate() {
 
         IntStream.range(0, NUM_INCREMENTS)
                 .forEach(i -> {
-                    Runnable task = () -> {
-                        IntBinaryOperator operator = (a, b) -> a + b;
-                        atomicInt.accumulateAndGet(i, operator);
-                    };
+                    Runnable task = () ->
+                            atomicInt.accumulateAndGet(i, (n, m) -> n + m);
                     executor.submit(task);
                 });