/**
 * 共享數(shù)據(jù)類
 * - foodflag: 食物狀態(tài)標記(0=無食物，1=有食物)
 * - count: 剩余食物數(shù)量
 * - lock: 同步鎖對象
 */
public class Desk {
    public static int foodflag = 0;
    public static int count = 10;
    public static final Object lock = new Object();
}

/**
 * 生產(chǎn)者線程 - 廚師
 */
public class Cook extends Thread {
    @Override
    public void run() {
        while (true) {
            synchronized (Desk.lock) {
                // 如果食物已全部生產(chǎn)完成，則退出
                if (Desk.count == 0) {
                    break;
                }
                
                // 如果還有食物未被消費，則等待
                if (Desk.foodflag == 1) {
                    try {
                        Desk.lock.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                } else {
                    // 生產(chǎn)食物
                    System.out.println(Thread.currentThread().getName() + " 做了一碗面");
                    Desk.foodflag = 1;
                    // 通知消費者可以消費了
                    Desk.lock.notifyAll();
                }
            }
        }
        System.out.println(Thread.currentThread().getName() + " 停止生產(chǎn)");
    }
}

/**
 * 消費者線程 - 吃貨
 */
public class Foodie extends Thread {
    @Override
    public void run() {
        while (true) {
            synchronized (Desk.lock) {
                // 如果食物已全部消費完，則退出
                if (Desk.count == 0) {
                    Desk.lock.notifyAll();  // 確保生產(chǎn)者線程能退出
                    break;
                }
                
                // 如果沒有食物，則等待
                if (Desk.foodflag == 0) {
                    try {
                        Desk.lock.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                } else {
                    // 消費食物
                    Desk.count--;
                    System.out.println(Thread.currentThread().getName() + " 吃了一碗，還剩 " + Desk.count + " 碗");
                    Desk.foodflag = 0;
                    // 通知生產(chǎn)者可以生產(chǎn)了
                    Desk.lock.notifyAll();
                }
            }
        }
        System.out.println(Thread.currentThread().getName() + " 停止消費");
    }
}

/**
 * 測試類
 */
public class Main {
    public static void main(String[] args) {
        // 創(chuàng)建并啟動生產(chǎn)者線程
        Cook cook = new Cook();
        cook.setName("廚師");
        
        // 創(chuàng)建并啟動消費者線程
        Foodie foodie = new Foodie();
        foodie.setName("吃貨");
        
        cook.start();
        foodie.start();
    }
}

synchronized (Desk.lock) {
    // 臨界區(qū)代碼
}