www.pudn.com > ThinkinginJava4thEdition(SourceCode).zip > AtomicIntegerTest.java

//: concurrency/AtomicIntegerTest.java 
import java.util.concurrent.*; 
import java.util.concurrent.atomic.*; 
import java.util.*; 
 
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) { 
    new Timer().schedule(new TimerTask() { 
      public void run() { 
        System.err.println("Aborting"); 
        System.exit(0); 
      } 
    }, 5000); // Terminate after 5 seconds 
    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); 
      } 
    } 
  } 
} ///:~