Java AtomicInteger Example (original) (raw)

This is an example of how to use the AtomicInteger class of Java. The java.util.concurrent.atomic package provides very useful classes that support lock-free and thread-safe programming on single variables. Among them, the AtomicInteger class is a wrapper class for an int value that allows it to be updated atomically. The class provides useful methods, some of which will be shown in the code snippet below.

The most common use of the AtomicInteger is to handle a counter that is accessed by different threads simultaneously. In order to see how this works, we will create and run two Threads, each one of which will access and update an AtomicInteger variable, using its API methods. The basic methods used in the example are described in short:

With incrementAndGet() API method, the value is incremented and its new value is returned.
With getAndIncrement() API method, the value is incremented, but its previous value is returned.
With addAndGet(int delta) API method, the delta is added to the value and the new value is returned, whereas there is also a getAndAdd(int delta) method that adds the delta to the value, but returns the previous value.
With compareAndSet(int expect, int update) API method, the value is compared to the expect param, and if they are equal, then the value is set to the update param and true is returned.
You can get the int, long, float or double value of the AtomicInteger variable, using intValue(), longValue(), floatValue() and doubleValue() methods respectivelly.

AtomicIntegerExample.java

package com.javacodegeeks.snippets.core;

import java.util.concurrent.atomic.AtomicInteger;

public class AtomicIntegerExample {

private static AtomicInteger at = new AtomicInteger(0);

static class MyRunnable implements Runnable {

    private int myCounter;
    private int myPrevCounter;
    private int myCounterPlusFive;
    private boolean isNine;

    public void run() {
        myCounter = at.incrementAndGet();
        System.out.println("Thread " + Thread.currentThread().getId() + "  / Counter : " + myCounter);
        myPrevCounter = at.getAndIncrement();
        System.out.println("Thread " + Thread.currentThread().getId() + " / Previous : " + myPrevCounter); 
        myCounterPlusFive = at.addAndGet(5);		
        System.out.println("Thread " + Thread.currentThread().getId() + " / plus five : " + myCounterPlusFive);
        isNine = at.compareAndSet(9, 3);
        if (isNine) {
            System.out.println("Thread " + Thread.currentThread().getId() 
                    + " / Value was equal to 9, so it was updated to " + at.intValue());
        }

    }
}

public static void main(String[] args) {
    Thread t1 = new Thread(new MyRunnable());
    Thread t2 = new Thread(new MyRunnable());
    t1.start();
    t2.start();
}

}

If you run the example, you will see that both threads can update the AtomicInteger variable atomically.

Output

Thread 9 / Counter : 1 Thread 10 / Counter : 2 Thread 9 / Previous : 2 Thread 9 / plus five : 9 Thread 9 / Value was equal to 9, so it was updated to 3 Thread 10 / Previous : 3 Thread 10 / plus five : 8

Download the Eclipse Project

This was an example of the AtomicInteger class of Java.

Theodora has graduated from Computer Engineering and Informatics Department in the University of Patras. She also holds a Master degree in Economics from the National and Technical University of Athens. During her studies she has been involved with a large number of projects ranging from programming and software engineering to telecommunications, hardware design and analysis. She works as a junior Software Engineer in the telecommunications sector where she is mainly involved with projects based on Java and Big Data technologies.