Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import java.util.concurrent.ExecutorService;
- import java.util.concurrent.Executors;
- import java.util.concurrent.TimeUnit;
- import java.util.concurrent.atomic.AtomicInteger;
- class AtomicCounter {
- private AtomicInteger count = new AtomicInteger(0);
- public int incrementAndGet() {
- return count.incrementAndGet();
- }
- public int getCount() {
- return count.get();
- }
- }
- public class AtomicIntegerExample {
- public static void main(String[] args) throws InterruptedException {
- ExecutorService executorService = Executors.newFixedThreadPool(2);
- AtomicCounter atomicCounter = new AtomicCounter();
- for(int i = 0; i < 1000; i++) {
- executorService.submit(() -> atomicCounter.incrementAndGet());
- }
- executorService.shutdown();
- executorService.awaitTermination(60, TimeUnit.SECONDS);
- System.out.println("Final Count is : " + atomicCounter.getCount());
- }
- }
- // Output
- // Final Count is : 1000
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement