java 生产者消费者_Java多线程：线程间通信—生产者消费者模型

/**
* 协作模型：生产者消费者模型实现：管程法
*/
public class Cooperation1 {
    public static void main(String[] args) {
        Container container = new Container();
        new Producer(container).start();
        new Consumer(container).start();
    }
}
 
/**
* 生产者
*/
class Producer extends Thread{
    Container container;
    public Producer(Container container){
        this.container = container;
    }
    @Override
    public void run() {
        //生产过程
        for (int i=0; i<10; i++){
            System.out.println("生产第 " + i + " 个馒头");
            container.push(new Hamburger(i));
        }
    }
}
 
/**
* 消费者
*/
class Consumer extends Thread{
    Container container;
    public Consumer(Container container){
        this.container = container;
    }
    @Override
    public void run() {
        //消费过程
        for (int i=0; i<10; i++){
            System.out.println("消费第 " + container.pop().id + " 个馒头");
        }
    }
}
 
/**
* 缓冲区，操作商品，并和生产者、消费者交互
*/
class Container{
    Hamburger[] food = new Hamburger[10];
    private int count = 0;
    //存储：生产
    public synchronized void push(Hamburger hamburger){
        if (count == food.length){
            try {
                this.wait();//阻塞，但是等待消费者通知后会解除
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        food[count++] = hamburger;
        this.notifyAll();//说明存在数据了，通知消费者消费
    }
    //获取：消费
    public synchronized Hamburger pop(){
        if (count ==0 ){
            try {
                this.wait();//阻塞，直到生产者通知后会解除
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        Hamburger ans = food[--count];
        this.notifyAll();//存在空余空间了，通知生产者生产
        return ans;
    }
}
 
/**
* 商品
*/
class Hamburger{
    int id;
    public Hamburger(int id) {
        this.id = id;
    }
}

/**
* 协作模型：生产者消费者实现：信号灯法
*/
public class Cooperation2 {
    public static void main(String[] args) {
        TV tv = new TV();
        new Actor(tv).start();
        new Fans(tv).start();
    }
}
/**
* 生产者：演员
*/
class Actor extends Thread{
    TV tv;
    public Actor(TV tv){
        this.tv = tv;
    }
    @Override
    public void run() {
        for (int i=0; i<10; i++){
            if (i%2 == 0){
                this.tv.play("节目 " + i);
            }else{
                this.tv.play("广告 " + i);
            }
        }
    }
}
/**
* 消费者：观众
*/
class Fans extends Thread{
    TV tv;
    public Fans(TV tv){
        this.tv = tv;
    }
    @Override
    public void run() {
        for (int i=0; i<10; i++){
            tv.watch();
        }
    }
}
 
/**
* 共同资源：电视直播
*/
class TV{
    String voice;
    //信号灯，如果为真则演员准备，观众等待
    //如果为假，则观众就位，演员等待
    boolean flag = true;
 
    //表演方法：针对生产者
    public synchronized void play(String voice){
        //演员等待
        if (!flag){
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        this.voice = voice;
        System.out.println("表演 "+voice +" ing");
        //唤醒观众
        this.notifyAll();
        this.flag = !flag;
    }
 
    //观看方法：针对消费者
    public synchronized void watch(){
        //观众等待
        if (flag){
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("观看 " + voice +" ing");
        this.notifyAll();
        this.flag = !flag;
    }
}