java 多線程-生產者消費者模式-管程法

生產者消費者模式管程法
通過容器中介，將數據放入和取出

wait()導致當前線程等待，直到另一個線程調用該對象的notify()或notyfyAll()方法
notify()喚醒正在等待對象監視器的單個線程,notifyAll()喚醒正在等待對象監視器的所有線程

public class tuble {
public static void main(String[]args)
{
    SynContainer container=new SynContainer();
    new Productor(container).start();
    new Productor(container).start();
    new Consumer(container).start();
}

}
//生產者，將數據存入容器
class Productor extends Thread
{
    SynContainer container;
public Productor(SynContainer container)
{
    this.container=container;
}
public void run()
{

        for(int i=0;i<100;i++)
        {
            System.out.println("生產第"+i+"個饅頭");
            container.push(new Data(i));
        }

}
}
//消費者，將數據從容器取出
class Consumer extends Thread
{
SynContainer container;
public Consumer(SynContainer container)
{
    this.container=container;
}
public void run()
{
    for(int i=0;i<100;i++)
    {
        System.out.println("消費第"+container.pop().id+"個饅頭");

    }
}
}
//緩沖區
class SynContainer 
{
Data[] datas=new Data[10]; //緩沖區里面存取數據
int count=0;//計數器
//存
public synchronized void push(Data data)
{
    //何時能生產
    if(count==datas.length)
    {
        try {
            this.wait();//線程阻塞，消費者通知生產才解除阻塞
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    datas[count]=data;
    count++;
    this.notify(); //存在數據，通知消費者可消費
}
//取
public synchronized Data  pop()
{
    //何時能取:
    if(count==0)
    {
        try {
            this.wait();//線程阻塞，生產者通知消費解除阻塞
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    count--;
    Data data=datas[count];
    this.notifyAll();//存在空間，通知生產者可生產
    return data;
}
}
//數據
class Data 
{
int id;
public Data(int id)
{
    this.id=id;
}
}