package concurrency;

import java.util.concurrent.*;

import java.util.concurrent.atomic.*;

import java.util.*;

/**

* RUN:

* javac concurrency/AtomicIntegerTest.java && java concurrency.AtomicIntegerTest

*

* OUTPUT:

*

*/

public class AtomicIntegerTest implements Runnable {

private AtomicInteger i = new AtomicInteger(0);

public int getValue() { return i.get(); }

private void evenIncrement() { i.addAndGet(2); }

public void run() {

while (true) {

evenIncrement();

}

}

public static void main(String[] args) {

// end through 5 seconds

new Timer().schedule(new TimerTask() {

public void run() {

System.err.println("Aborting");

System.exit(0);

}

}, 5000);

ExecutorService exec = Executors.newCachedThreadPool();

AtomicIntegerTest ait = new AtomicIntegerTest();

exec.execute(ait);

while (true) {

int val = ait.getValue();

if (val % 2 != 0) {

System.out.println(val);

System.exit(0);

}

}

}

}