public class ProducerConsumer {
public static void main(String[] args) {
SyncStack ss = new SyncStack();
Producer p = new Producer(ss);
Consumer c = new Consumer(ss);
new Thread(p).start();

new Thread(c).start();
}
}
//栈内存放的对象
class WoTou {
int id; 
WoTou(int id) {
this.id = id;
}
public String toString() {
return "WoTou" + id+"号";
}
}
//建立栈
class SyncStack {
int index = 0;
WoTou[] arrWT = new WoTou[6];
//压栈方法
public synchronized void push(WoTou wt) {
while(index == arrWT.length) {
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
this.notifyAll();
arrWT[index] = wt;
index ++;
}
//出栈方法
public synchronized WoTou pop() {
while(index == 0) {
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
this.notifyAll();
index--;
return arrWT[index];
}
}class Producer implements Runnable {
SyncStack ss = null;
Producer(SyncStack ss) {
this.ss = ss;      
}

public void run() {
for(int i=0; i<20; i++) {
WoTou wt = new WoTou(i);
ss.push(wt);
System.out.println("生产了:" + wt+"     剩余"+ss.index);
try {
Thread.sleep((int)(Math.random() * 200));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}class Consumer implements Runnable {
SyncStack ss = null;
Consumer(SyncStack ss) {
this.ss = ss;
}

public void run() {
for(int i=0; i<20; i++) {
WoTou wt = ss.pop();
System.out.println("消费了: " + wt+"     剩余"+ss.index);
try {
Thread.sleep((int)(Math.random() * 1000));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}这个程序运行起来,我发现输出结果中剩余的数量有时候不随生产的增加而增加,或者不随消费的减少而减少
比如我的一次运行结果:
生产了:WoTou0号     剩余1
消费了: WoTou0号     剩余0
生产了:WoTou1号     剩余0
消费了: WoTou1号     剩余0
最后两行,生产之后,栈内数量没变。请高手指点一下