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

“只有客戶發(fā)展了，才有我們的生存與發(fā)展！”這是創(chuàng)新互聯(lián)的服務(wù)宗旨！把網(wǎng)站當(dāng)作互聯(lián)網(wǎng)產(chǎn)品，產(chǎn)品思維更注重全局思維、需求分析和迭代思維，在網(wǎng)站建設(shè)中就是為了建設(shè)一個(gè)不僅審美在線，而且實(shí)用性極高的網(wǎng)站。創(chuàng)新互聯(lián)對(duì)成都網(wǎng)站設(shè)計(jì)、網(wǎng)站制作、網(wǎng)站制作、網(wǎng)站開(kāi)發(fā)、網(wǎng)頁(yè)設(shè)計(jì)、網(wǎng)站優(yōu)化、網(wǎng)絡(luò)推廣、探索永無(wú)止境。

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

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無(wú)理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性?xún)r(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專(zhuān)為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。

當(dāng)前題目：java多線程-生產(chǎn)者消費(fèi)者模式-管程法-創(chuàng)新互聯(lián)
URL標(biāo)題：http://weahome.cn/article/iepig.html