Java生产者和消费者实现等待唤醒机制

/**
 * 共享数据类
 * - foodflag: 食物状态标记(0=无食物，1=有食物)
 * - count: 剩余食物数量
 * - lock: 同步锁对象
 */
public class Desk {
    public static int foodflag = 0;
    public static int count = 10;
    public static final Object lock = new Object();
}

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

/**
 * 消费者线程 - 吃货
 */
public class Foodie extends Thread {
    @Override
    public void run() {
        while (true) {
            synchronized (Desk.lock) {
                // 如果食物已全部消费完，则退出
                if (Desk.count == 0) {
                    Desk.lock.notifyAll();  // 确保生产者线程能退出
                    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;
                    // 通知生产者可以生产了
                    Desk.lock.notifyAll();
                }
            }
        }
        System.out.println(Thread.currentThread().getName() + " 停止消费");
    }
}

/**
 * 测试类
 */
public class Main {
    public static void main(String[] args) {
        // 创建并启动生产者线程
        Cook cook = new Cook();
        cook.setName("厨师");
        
        // 创建并启动消费者线程
        Foodie foodie = new Foodie();
        foodie.setName("吃货");
        
        cook.start();
        foodie.start();
    }
}

synchronized (Desk.lock) {
    // 临界区代码
}