package concurrency;

import java.util.concurrent.*;

import java.util.concurrent.locks.*;

/**

* RUN:

* javac concurrency/AtomicityTest.java && java concurrency.AtomicityTest

*

* OUTPUT:

*

*/

public class AtomicityTest implements Runnable {

private int i = 0;

public int getValue() { return i; }

private synchronized void evenIncrement() {

i++; ++i;

}

public void run() {

while (true) {

evenIncrement();

}

}

public static void main(String[] args) {

ExecutorService exec = Executors.newCachedThreadPool();

AtomicityTest at = new AtomicityTest();

exec.execute(at);

while (true) {

int val = at.getValue();

if (val % 2 != 0) {

System.out.println(val);

System.exit(0);

}

}

}

}