package com.zetcode;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.TimeUnit;

import java.util.concurrent.atomic.AtomicLong;

public class AtomicLongEx2 {

private static AtomicLong sum = new AtomicLong();

public static void main(String[] args) throws InterruptedException {

for (int i = 0; i < 5; i++) {

sum.set(0);

ExecutorService executorService = Executors.newFixedThreadPool(50);

for (int j = 1; j <= 50; j++) {

int finalI = i;

executorService.execute(() -> sum.addAndGet(finalI));

}

executorService.shutdown();

executorService.awaitTermination(3, TimeUnit.SECONDS);

System.out.println(sum);

}

}

}