CAS (Compare And Swap)

AtomicThread.java

import java.util.concurrent.atomic.*;

public final class AtomicThread {
    private static final int NUM_LOAD = 100000;
    private AtomicInteger count = new AtomicInteger();

    private static class Worker implements Runnable {
        private AtomicThread counter = null;
 
        public Worker(AtomicThread counter) {
            this.counter = counter;
        }

        @Override
        public void run() {
            for (int i = 0; i < AtomicThread.NUM_LOAD; i++) {
                this.counter.count.getAndIncrement();
            }
        }
    }

    public AtomicThread() {
    }

    public AtomicInteger getCount() {
        return this.count;
    }

    public static void main(String[] args) throws InterruptedException {
        AtomicThread counter = new AtomicThread();

        Thread thread1 = new Thread(new Worker(counter));
        Thread thread2 = new Thread(new Worker(counter));

        thread1.start();
        thread2.start();
 
        thread1.join();
        thread2.join();

        System.out.println(counter.getCount());
    }
}