JAVA生產(chǎn)者消費(fèi)者(線程同步)代碼學(xué)習(xí)示例

2019-11-26 15:53:22

字體：大中小

供稿：網(wǎng)友

一、問題描述

生產(chǎn)者消費(fèi)者問題是一個典型的線程同步問題。生產(chǎn)者生產(chǎn)商品放到容器中，容器有一定的容量（只能順序放，先放后拿），消費(fèi)者消費(fèi)商品，當(dāng)容器滿了后，生產(chǎn)者等待，當(dāng)容器為空時，消費(fèi)者等待。當(dāng)生產(chǎn)者將商品放入容器后，通知消費(fèi)者；當(dāng)消費(fèi)者拿走商品后，通知生產(chǎn)者。

二、解決方案

對容器資源加鎖，當(dāng)取得鎖后，才能對互斥資源進(jìn)行操作。

復(fù)制代碼代碼如下:

public class ProducerConsumerTest {

    public static void main(String []args){
        Container con = new Container();
        Producer p = new Producer(con);
        Consumer c = new Consumer(con);
        new Thread(p).start();
        new Thread(c).start();
    }

}

class Goods{
    int id;
    public Goods(int id){
        this.id=id;
    }

    public String toString(){
        return "商品"+this.id;
    }
}

class Container{//容器采用棧，先進(jìn)后出
    private int index = 0;
    Goods[] goods = new Goods[6];

    public synchronized void push(Goods good){
        while(index==goods.length){//當(dāng)容器滿了，生產(chǎn)者等待
            try {
                wait();
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        goods[index]=good;
        index++;
        notifyAll();//當(dāng)生產(chǎn)者放入商品后通知消費(fèi)者
    }

    public synchronized Goods pop(){
        while(index==0){//當(dāng)容器內(nèi)沒有商品是等待
            try {
                wait();
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        index--;
        notifyAll();//當(dāng)消費(fèi)者消費(fèi)了商品后通知生產(chǎn)者
        return goods[index];
    }
}

class Producer implements Runnable{

    Container con = new Container();
    public Producer(Container con){
        this.con=con;
    }

    public void run(){
        for(int i=0; i<20; i++){
            Goods good = new Goods(i);
            con.push(good);
            System.out.println("生產(chǎn)了："+good);
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }

}

class Consumer implements Runnable{

    Container con = new Container();
    public Consumer(Container con){
        this.con=con;
    }

    public void run(){
        for(int i=0; i<20; i++){
            Goods good=con.pop();
            System.out.println("消費(fèi)了："+good);
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }


}