多線程20：管程法

解決方式1：

 

並發協作模型"生產者/消費者模式"--->管程法

• 生產者：負責生產數據的模塊(可能是方法，對象，線程，進程)
• 消費者：負責處理數據的模塊(可能是方法，對象，線程，進程)
• 緩沖區：消費者不能直接使用生產者的數據，他們之間有個緩沖區，生產者將生產好的數據放入緩沖區，消費者從緩沖區拿出數據

 

思路:

1.首先有一個生產者，消費者、生產者只顧生產，消費者只管消費、

2.利用了一個緩沖區，緩沖了一個10個大小的數組

3.有個方法叫放入產品，產品丟進來的時候，我們判斷一下緩沖區有沒有滿，如果滿了的話，生產者就要等待了，

如果沒有滿，就將產品放進去，放進去之后有產品了，趕緊通知消費者消費

4.消費者就判斷下能不能消費呢，有沒有東西，有東西的話，我就可以直接消費，消費完了，就趕緊通知生產者生產。

如果沒有東西呢，消費者就等待。等待生產者去通知他，生產者通知了，他就可以解除等待了。

package com.thread.gaoji;

//測試: 生產者消費者模型-->利用緩沖區解決：管程法

//生產者 ， 消費者 ， 產品 ， 緩沖區
public class TestPC {

    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) {
        this.container = container;
    }

    //生產
    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            container.push(new Chicken(i));
            System.out.println("生產了" + i + "只雞");
        }
    }
}

//消費者
class Consumer extends Thread {
    SynContainer container;

    public Consumer(SynContainer container) {
        this.container = container;
    }

    //消費
    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            System.out.println("消費了-->" + container.pop().id + "只雞");
        }
    }
}

//產品
class Chicken {
    int id;//編號

    public Chicken(int id) {
        this.id = id;
    }
}

//緩沖區
class SynContainer {

    //需要一個容器大小
    Chicken[] chickens = new Chicken[10];

    //容器計數器
    int count = 0;

    //生產者放入產品
    public synchronized void push(Chicken chicken) {
        //如果容器滿了，就需要等待消費者消費
        if (count == chickens.length) {
            //生產者等待
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        //如果沒有滿，我們需要丟入產品
        chickens[count] = chicken;
        count++;

        //可以通知消費者消費了.
        this.notifyAll();
    }

    //消費者消費產品
    public synchronized Chicken pop() {
        //判斷能否消費
        if (count == 0) {
            //消費者等待
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        //如果可以消費
        count--;
        Chicken chicken = chickens[count];

        //吃完了，通知生產者生產
        this.notifyAll();
        return chicken;
    }
}