Atomic update

Author: winterbe

src/com/winterbe/java8/samples/concurrent/Atomic1.java

@@ -18,6 +18,24 @@ public class Atomic1 {
  public static void main(String[] args) {
  testIncrement();
  testAccumulate();
+ testUpdate();
+ }
+
+ private static void testUpdate() {
+ atomicInt.set(0);
+
+ ExecutorService executor = Executors.newFixedThreadPool(2);
+
+ IntStream.range(0, NUM_INCREMENTS)
+ .forEach(i -> {
+ Runnable task = () ->
+ atomicInt.updateAndGet(n -> n + 2);
+ executor.submit(task);
+ });
+
+ ConcurrentUtils.stop(executor);
+
+ System.out.format("Update: %d\n", atomicInt.get());
  }
 
  private static void testAccumulate() {

src/com/winterbe/java8/samples/concurrent/ConcurrentUtils.java

@@ -11,7 +11,7 @@ public class ConcurrentUtils {
  public static void stop(ExecutorService executor) {
  try {
  executor.shutdown();
- executor.awaitTermination(5, TimeUnit.SECONDS);
+ executor.awaitTermination(60, TimeUnit.SECONDS);
  }
  catch (InterruptedException e) {
  System.err.println("termination interrupted");