多线程_并发协作_管程法

/**
 * 多线程_并发协作_管程法
 *
 * @author: mhSui 2020/04/21
 */
public class Test01 {
    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 synchronized void run() {
        //生产玩具
        for (int i = 0;i < 100;i++){
            System.out.println("生产-->"+ i +"个玩具");
            container.push(new ProductNum(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 SynContainer{
    //存储容器
    ProductNum[] productNums = new ProductNum[10];
    //计数器
    int count = 0;
    //存储 生产
    public synchronized void push(ProductNum productNum){
        //何时能生产 容器存在空间
        //不能生产
        if (count == productNums.length){
            try {
                this.wait();//线程阻塞 消费者者通知生产者解除
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        productNums[count] = productNum;
        count++;
        //存在数据了，通知消费者消费数据
        this.notifyAll();
    }

    //消费 获取
    public synchronized ProductNum pop(){
        //何时消费 容器中是否存在数据
        //没有数据 只有等待
        if (count == 0){
            try {
                this.wait();//线程阻塞 生产通知消费解除
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        //存在数据可以消费
        count--;
        ProductNum productNum = productNums[count];
        this.notifyAll();//存在空间 唤醒生产者生产
        return productNum;
    }
}

//生产的产品
class ProductNum{
  int id;//给生产的产品加个编号
  public ProductNum(int id){
      this.id = id;
  }
}