java 多線程-生產(chǎn)者消費(fèi)者模式-管程法

生產(chǎn)者消費(fèi)者模式管程法
通過容器中介，將數(shù)據(jù)放入和取出

wait()導(dǎo)致當(dāng)前線程等待，直到另一個(gè)線程調(diào)用該對(duì)象的notify()或notyfyAll()方法
notify()喚醒正在等待對(duì)象監(jiān)視器的單個(gè)線程,notifyAll()喚醒正在等待對(duì)象監(jiān)視器的所有線程

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();
}

}
//生產(chǎn)者，將數(shù)據(jù)存入容器
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("生產(chǎn)第"+i+"個(gè)饅頭");
            container.push(new Data(i));
        }

}
}
//消費(fèi)者，將數(shù)據(jù)從容器取出
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("消費(fèi)第"+container.pop().id+"個(gè)饅頭");

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