//倉(cāng)庫(kù) - 唯一（鎖對(duì)象，任何對(duì)象都可以，用共有對(duì)象做鎖對(duì)象）
class CangKu { //當(dāng)作 鎖對(duì)象
    //定義一個(gè)變量體現(xiàn)數(shù)量
    public int productNum = 0;
}
//生產(chǎn)方和消費(fèi)方共用一個(gè)倉(cāng)庫(kù)
//生產(chǎn)方
class ProductTask implements Runnable {
    private CangKu cangKu; //共用一個(gè)倉(cāng)庫(kù)不能自己創(chuàng)建，由外部傳入
    public ProductTask(CangKu cangKu) { //通過構(gòu)造函數(shù)初始化
        this.cangKu = cangKu;
    }
    @Override
    public void run() {
        while (true) {
            //通知notify與等待wait必須寫在同步代碼塊中
            synchronized (this.cangKu) {//判斷是否有鎖可用，有就進(jìn)入
                if (this.cangKu.productNum == 0) {
                    ++this.cangKu.productNum;   //生產(chǎn)數(shù)目+1
                    System.out.println("生產(chǎn)了一個(gè)產(chǎn)品，當(dāng)前產(chǎn)品數(shù)目：" + this.cangKu.productNum);
                    //通知消費(fèi)者，必須用同一個(gè)鎖對(duì)象，不然會(huì)造成死鎖
                    this.cangKu.notify();
                } else {
                    //當(dāng)前還有存貨不用生產(chǎn)，等待通知
                    try {
                        System.out.println("生產(chǎn)方等待中...");
                        this.cangKu.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }//end if
            }//end synchronized 出房間釋放鎖
        }
    }
}
//消費(fèi)方
class ConsumerTask implements Runnable {
    private CangKu cangKu;
    public ConsumerTask(CangKu cangKu) {    //構(gòu)造方法
        this.cangKu = cangKu;
    }
    @Override
    public void run() {
        while (true) {
            synchronized (this.cangKu) {
                //判斷，倉(cāng)庫(kù)是否為0
                if (this.cangKu.productNum == 0) {
                    try {
                        System.out.println("消費(fèi)方等待中...");
                        this.cangKu.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                } else {
                    //有貨可以吃
                    -- this.cangKu.productNum ;
                    System.out.println("消費(fèi)了一個(gè)產(chǎn)品，當(dāng)前產(chǎn)品數(shù)目：" + this.cangKu.productNum);
                    //通知生產(chǎn)方生產(chǎn)產(chǎn)品
                    this.cangKu.notify();
                }//end if
            }//end synchronized
        }
    }
}
public class Wait_Notify_Demo {
    public static void main(String[] args) {
        //任務(wù)對(duì)象（生產(chǎn)方和消費(fèi)方共用一個(gè)倉(cāng)庫(kù)）
        CangKu cangKu = new CangKu();
        ProductTask productTask = new ProductTask(cangKu);
        ConsumerTask consumerTask = new ConsumerTask(cangKu);
        //定義線程（用Executors線程池）
        ExecutorService pool = Executors.newFixedThreadPool(2);
        pool.submit(productTask);   //生產(chǎn)
        pool.submit(consumerTask);  //消費(fèi)
    }
}