第四版的,Concurrency那一章里的一个源码CriticalSection.java, 在Ubuntu里编译可以通过,运行也没有异常,static void testApproaches(PairManager pman1, PairManager pman2)里一直运行不到System.out.println("pm1: "+pm1 + "\npm2: "+pm2);那一句,也就是说什么也不能输出,但是在win7下就可以正确运行,我两个系统都使用的是JDK1.7.0。想请教一下大家这是怎么回事,要是我想要让这个程序能在Ubuntu运行,需要做什么改动。
源码如下
package concurrency;import java.util.concurrent.*;import java.util.concurrent.atomic.*;import java.util.*;class Pair { // Not thread-safe  private int x, y;  public Pair(int x, int y) {    this.x = x;    this.y = y;  }  public Pair() { this(0, 0); }  public int getX() { return x; }  public int getY() { return y; }  public void incrementX() { x++; }  public void incrementY() { y++; }  public String toString() {    return "x: " + x + ", y: " + y;  }  public class PairValuesNotEqualException  extends RuntimeException {    public PairValuesNotEqualException() {      super("Pair values not equal: " + Pair.this);    }  }  // Arbitrary invariant -- both variables must be equal:  public void checkState() {    if(x != y)      throw new PairValuesNotEqualException();  }}// Protect a Pair inside a thread-safe class:abstract class PairManager {  AtomicInteger checkCounter = new AtomicInteger(0);  protected Pair p = new Pair();  private List<Pair> storage =    Collections.synchronizedList(new ArrayList<Pair>());  public synchronized Pair getPair() {    // Make a copy to keep the original safe:    return new Pair(p.getX(), p.getY());  }  // Assume this is a time consuming operation  protected void store(Pair p) {    storage.add(p);    try {      TimeUnit.MILLISECONDS.sleep(50);    } catch(InterruptedException ignore) {}  }  public abstract void increment();}// Synchronize the entire method:class PairManager1 extends PairManager {  public synchronized void increment() {    p.incrementX();    p.incrementY();    store(getPair());  }}// Use a critical section:class PairManager2 extends PairManager {  public void increment() {    Pair temp;    synchronized(this) {      p.incrementX();      p.incrementY();      temp = getPair();    }    store(temp);  }}class PairManipulator implements Runnable {  private PairManager pm;  public PairManipulator(PairManager pm) {    this.pm = pm;  }  public void run() {    while(true)      pm.increment();  }  public String toString() {    return "Pair: " + pm.getPair() +      " checkCounter = " + pm.checkCounter.get();  }}class PairChecker implements Runnable {  private PairManager pm;  public PairChecker(PairManager pm) {    this.pm = pm;  }  public void run() {    while(true) {      pm.checkCounter.incrementAndGet();      pm.getPair().checkState();    }  }}public class CriticalSection {  // Test the two different approaches:  static void  testApproaches(PairManager pman1, PairManager pman2) {    ExecutorService exec = Executors.newCachedThreadPool();    PairManipulator      pm1 = new PairManipulator(pman1),      pm2 = new PairManipulator(pman2);    PairChecker      pcheck1 = new PairChecker(pman1),      pcheck2 = new PairChecker(pman2);    exec.execute(pm1);    exec.execute(pm2);    exec.execute(pcheck1);    exec.execute(pcheck2);    try {      TimeUnit.MILLISECONDS.sleep(500);    } catch(InterruptedException e) {      System.out.println("Sleep interrupted");    }    System.out.println("pm1: " + pm1 + "\npm2: " + pm2);    System.exit(0);  }  public static void main(String[] args) {    PairManager      pman1 = new PairManager1(),      pman2 = new PairManager2();    testApproaches(pman1, pman2);  }} /* Output: (Sample)pm1: Pair: x: 15, y: 15 checkCounter = 272565pm2: Pair: x: 16, y: 16 checkCounter = 3956974*///:~