總體概述：

所謂生產者消費者問題，實際上主要是包含了兩類執行緒:

• 一類是生產者執行緒用于生產資料
• 一類是消費者執行緒用于消費資料

為了解耦生產者和消費者的關系，通常會采用共享的資料區域，就像是一個倉庫，

• 生產者生產資料之后直接放置在共享資料區中，并不需要關心消費者的行為
• 消費者只需要從共享資料區中去獲取資料，并不需要關心生產者的行為

執行緒生命周期：

案例分析：

生產者消費者案例中包含的類:

• 奶箱類(Box):定義一個成員變數，表示第x瓶奶，提供存盤牛奶和獲取牛奶的操作
• 生產者類(Producer):實作Runnable介面，重寫run()方法，呼叫存盤牛奶的操作
• 消費者類(Customer):實作Runnable介面，重寫run()方法，呼叫獲取牛奶的操作
• 測驗類(BoxTestt):里面有main方法，main方法中的代碼步驟如下：

①創建奶箱物件，這是共享資料區域

②創建生產者物件，把奶箱物件作為構造方法引數傳遞，因為在這個類中要呼叫存盤牛奶的操作

③創建消費者物件，把奶箱物件作為構造方法引數傳遞，因為在這個類中要呼叫獲取牛奶的操作

④創建2個執行緒物件，分別把生產者物件和消費者物件作為構造方法引數傳遞

⑤啟動執行緒

結果預覽：

具體實作：

下面是存盤牛奶和獲取牛奶的操作

  //定義一個成員變數，用來表示第x瓶牛奶
    private  int milk;
    //定義一個成員變數 用于表示牛奶箱子狀態
    private boolean state=false;

    //提供存盤牛奶和獲取牛奶的操作
public synchronized void putMilk(int milk){
if(state){
    try {
        wait();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}
    //如果沒有牛奶  則生產牛奶
    this.milk=milk;
    System.out.println("送奶工人將第"+this.milk+"瓶牛奶放入奶箱");

    //生產完畢  修改牛奶箱子狀態
        state=true;
    //喚醒其他等待的執行緒
    notifyAll();

}

    public synchronized  void getMilk() {
    //如果沒有牛奶 等待生產
    if(!state){
        try {
            wait();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    //如果有牛奶 就消費牛奶
        System.out.println("用戶拿到第"+this.milk+"瓶牛奶");
    //  生產完畢  修改牛奶狀態
             state=false;
    //喚醒其他等待的執行緒
        notifyAll();

    }

原碼：

生產者類：

package MultithreadingCase;

public class Producer implements Runnable{
    private final Box b;
    public Producer(Box b) {
        this.b=b;
    }

    @Override
    public void run() {
        //送奶工人將50瓶牛奶放入奶箱
        for(int i=1;i<=50;i++){

            b.putMilk(i);


        }

    }
}

消費者類：

package MultithreadingCase;

public class Customer implements Runnable{
    private final Box b;
    public Customer(Box b) {
        this.b=b;
    }

    @Override
    public void run() {
        while (true){

          b.getMilk();

        }

    }
}

主類測驗：

package MultithreadingCase;

public class BoxTest {
    public static void main(String[] args) {
        //創建奶箱物件   用于共享資料
        Box box=new Box();
        //創建生產者物件  把奶箱物件（box）作為構造方法引數傳遞  呼叫存盤牛奶操作
        Producer p=new Producer(box);
        //創建消費者物件  把奶箱物件（box）作為構造方法引數傳遞  呼叫獲取牛奶操作
        Customer c=new Customer(box);
        //創建兩個執行緒，把生產者物件和消費者物件作為構造方法引數傳進去
        Thread t1=new Thread(p);
        Thread t2=new Thread(c);

        //啟動兩個執行緒
        t1.start();
        t2.start();


    }
}

牛奶箱子類：

package MultithreadingCase;

public class Box {

    //定義一個成員變數，用來表示第x瓶牛奶
    private  int milk;
    //定義一個成員變數 用于表示牛奶箱子狀態
    private boolean state=false;

    //提供存盤牛奶和獲取牛奶的操作
public synchronized void putMilk(int milk){
if(state){
    try {
        wait();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}
    //如果沒有牛奶  則生產牛奶
    this.milk=milk;
    System.out.println("送奶工人將第"+this.milk+"瓶牛奶放入奶箱");

    //生產完畢  修改牛奶箱子狀態
        state=true;
    //喚醒其他等待的執行緒
    notifyAll();

}

    public synchronized  void getMilk() {
    //如果沒有牛奶 等待生產
    if(!state){
        try {
            wait();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    //如果有牛奶 就消費牛奶
        System.out.println("用戶拿到第"+this.milk+"瓶牛奶");
    //  生產完畢  修改牛奶狀態
             state=false;
    //喚醒其他等待的執行緒
        notifyAll();

    }
}