0

我试图编写一个代码，其中多个线程调用共享对象上的方法来递增/递减/打印存储在其中的计数器。我还想要这些数字在 0 和 8 之间波动。即输出可能如下所示：0123234567654566677877666655 ....

有人可以看看我所做的事情，并就我是否走在正确的轨道上给我一些指示：

我的共享对象：

public class SyncObj{
        private int i;
        public synchronized void inc(){
                if(i<8)
                  i++;
        }
        public synchronized void dec(){
                if(i > 0)
                   i--;
        }
        public synchronized void print(){
                System.out.print(i);
        }
}

为了防止打印出现饥饿并确保打印每个 inc/dec，我可以有一个名为 hasPrinted 的私有变量并重写该类，如下所示：

public class SyncObj{
            private int i;
            //Changed Boolean to boolean as Keith Randall pointed out
            private boolean hasPrinted = false;
            public synchronized void inc(){
                    if(i<8 && hasPrinted){
                      i++;
                      hasPrinted = false;
                    }
            }
            public synchronized void dec(){
                    if(i > 0 && hasPrinted){
                       i--;
                       hasPrinted = false;
                    }
            }
            public synchronized void print(){
                    System.out.print(i);
                    hasPrinted = true;
            }
    }

有人可以查看上面的片段并查看它的陷阱和陷阱吗？

谢谢

4

2 回答 2

1

Boolean-> boolean，没有必要使用对象而不是原始类型。

你的第一个代码很好。您的第二个代码不能解决您防止饥饿或确保打印每个 inc/dec 的要求。为什么不让 inc/dec 打印值本身？

于 2012-04-06T16:12:58.900 回答
1

您应该习惯于使用队列进行打印。

public class SyncObj {
  private volatile int i;
  private BlockingQueue<Integer> q = new LinkedBlockingQueue<Integer>();
  public synchronized void inc() {
    if (i < 8) {
      i++;
      q.add(i);
    }
  }
  public synchronized void dec() {
    if (i > 0) {
      i--;
      q.add(i);
    }
  }
  public void print() {
    for (Integer i = q.poll(); i != null; i = q.poll()) {
      System.out.print(i);
    }
  }
  private static volatile boolean stop = false;
  public static void main(String[] args) throws InterruptedException {
    final SyncObj o = new SyncObj();

    new Thread(new Runnable() {
      @Override
      public void run() {
        while (!stop) {
          o.inc();
        }
      }
    }).start();

    new Thread(new Runnable() {
      @Override
      public void run() {
        while (!stop) {
          o.dec();
        }
      }
    }).start();

    new Thread(new Runnable() {
      @Override
      public void run() {
        while (!stop) {
          o.print();
        }
      }
    }).start();

    Thread.currentThread().sleep(1000);
    stop = true;
  }
}

我的输出如下所示：

1012345678765432101234567876543210123456787654321012345678765432101234567876543210123456787654321012345678

于 2012-04-06T18:08:20.473 回答