* 第一：生产者 生产的消费品 存放到仓库中，当仓库满时，生产者停止生产 * 第二：消费者 到仓库中 使用消费品，当仓库没有消费品时,停止消费 * 第三：生产者 在仓库满停止生产后 通知消费者去消费

* 第四：消费者 在仓库没有消费品时 通知生产者生产

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(p).start(); 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]; //仓库只能存放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); 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); try { Thread.sleep((int)(Math.random() * 1000)); } catch (InterruptedException e) { e.printStackTrace(); } } } }