生产者--消费者实践

/**
* 一个场景，共同的资源
* 生产者消费者模式 	信号灯法
* wait()：等待，释放锁 	sleep()：不释放锁
* notify()：释放锁
* @author Administrator
*
*/
public class Movie {

private String pic;
//信号灯
//flag -->T 生产者生产，消费者等待，生产完成后通知消费
//flag -->F 消费者消费，生产者等待，消费完成后通知生产
private boolean flag = true;
/**
* 播放
* @param pic
*/
public synchronized void play(String pic){

if(!flag){//生产者等待
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//开始生产
try {
Thread.sleep(500);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("生产了"+pic);
//生产完毕
this.pic = pic;
//通知消费
this.notify();
//生产者停下
this.flag=false;
}

public synchronized void watch(){

if(flag){//消费者等待
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//开始消费
try {
Thread.sleep(200);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("消费了"+pic);
//消费完毕

//通知生产
this.notifyAll();
//消费停止
this.flag = true;

}
}

/**
* 生产者
* @author Administrator
*
*/
public class Player implements Runnable{

private Movie m;

public Player(Movie m) {
super();
this.m = m;
}

@Override
public void run() {

for(int i=0;i<20;i++){
if(i%2==0){
m.play("左青龙");
}else{
m.play("右白虎");
}
}
}

}

/**
* 消费者
* @author Administrator
*
*/
public class Watcher implements Runnable {

private Movie m;

public Watcher(Movie m) {
super();
this.m = m;
}

@Override
public void run() {

for(int i=0;i<20;i++){
m.watch();
}
}

}

public class App {

public static void main(String[] args) {

//共同的资源
Movie m = new Movie();

//线程
Player p = new Player(m);
Watcher w = new Watcher(m);

new Thread(p).start();
new Thread(w).start();
}
}