/*** 生产者消费者模型实现方式一：管程法* 4个角色： 生产者、消费者、缓冲区、生产的商品* */
package cn.sxt.thread;public class Test_0411_Produce {public static void main(String[] args) {SynContainer container=new SynContainer();new Productor(container).start();new Consumer(container).start();}
}
//生产者
class Productor extends Thread{SynContainer container;public Productor(SynContainer container) {super();this.container = container;}//开始生产，生产50个public void run() {    for (int i = 0; i < 50; i++) {System.out.println("生产-->第"+i+"个包子");container.push(new Goods(i));}}
}
//消费者
class Consumer extends Thread{SynContainer container;public Consumer(SynContainer container) {super();this.container = container;}//开始消费,消费100个会等待public void run() {    for (int i = 0; i < 100; i++) {System.out.println("消费---->第"+container.pop().id+"个包子");}}
}//缓冲区
class SynContainer {Goods[] goods=new Goods[10];int count;//存public synchronized void push(Goods good1) {//缓冲区有空格就生产if (count==goods.length) {//此种情况下表示缓冲区满了，不能生产try {this.wait();//线程阻塞。生产通知消费，解除阻塞} catch (InterruptedException e) {//消费者通知生产，就解除
                }}goods[count]=good1;count++;this.notifyAll();//存在数据了，可以唤醒消费者消费了
    }//取public synchronized Goods pop() {//存在数据就拿，没有数据就等待if (count==0) {try {this.wait();//线程阻塞。生产通知消费，解除阻塞} catch (InterruptedException e) {}}count--;//从最后一个位置拿Goods good2=goods[count];this.notifyAll();//存在空间可唤醒对方生产了return good2;}
}
//商品
class Goods {int id;public Goods(int id) {super();this.id = id;}}

/*** 生产者消费者模型实现方式二：信号灯法，借助标志位* 3要素：生产者(演员)、消费者(观众)、统一资源(电视剧)* */
package cn.sxt.thread;public class Test_0411_Signal {public static void main(String[] args) {Tv tv=new Tv();new Actor(tv).start();new Watcher(tv).start();        }
}class Actor extends Thread{Tv tv;public Actor(Tv tv) {this.tv = tv;}public void run() {for (int i = 0; i < 10; i++) {        if (i%2==0) {this.tv.play("知否知否应是绿肥红瘦");    }else {this.tv.play("香蜜沉沉烬如霜");}}}
}class Watcher extends Thread{Tv tv;public Watcher(Tv tv) {this.tv = tv;}public void run() {for (int i = 0; i < 10; i++) {tv.watch();            }}
}class Tv{String vioce;boolean flag=true;//信号灯 真：表示演员表演，观众等待   假：观众观看，演员等待public synchronized void play(String v) {//演员等待if (!flag) {try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}        }System.out.println("表演了:"+v);this.vioce=v;this.notifyAll();//唤醒 this.flag=!this.flag;//切换标志
    }public synchronized void watch() {//观众等待if (flag) {try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}        }System.out.println("听到了:"+vioce);this.notifyAll();//唤醒this.flag=!this.flag;}}