Java线程等待唤醒机制详解

class SharedResource {
    private int data;
    private boolean hasData = false;

    public synchronized void produce(int value) throws InterruptedException {
        while (hasData) {
            wait(); // 等待消费者消费
        }
        data = value;
        hasData = true;
        System.out.println("生产了: " + data);
        notify(); // 唤醒等待的消费者线程
    }

    public synchronized void consume() throws InterruptedException {
        while (!hasData) {
            wait(); // 等待生产者生产
        }
        System.out.println("消费了: " + data);
        hasData = false;
        notify(); // 唤醒等待的生产者线程
    }
}

public class WaitNotifyExample {
    public static void main(String[] args) {
        SharedResource resource = new SharedResource();

        Thread producer = new Thread(() -> {
            for (int i = 1; i  {
            for (int i = 1; i 

import java.util.concurrent.locks.*;

class BetterSharedResource {
    private int data;
    private boolean hasData = false;
    private final Lock lock = new ReentrantLock();
    private final Condition hasDataCondition = lock.newCondition();
    private final Condition noDataCondition = lock.newCondition();

    public void produce(int value) throws InterruptedException {
        lock.lock();
        try {
            while (hasData) {
                noDataCondition.await(); // 等待空位
            }
            data = value;
            hasData = true;
            System.out.println("生产了: " + data);
            hasDataCondition.signal(); // 唤醒消费者
        } finally {
            lock.unlock();
        }
    }

    public void consume() throws InterruptedException {
        lock.lock();
        try {
            while (!hasData) {
                hasDataCondition.await(); // 等待数据
            }
            System.out.println("消费了: " + data);
            hasData = false;
            noDataCondition.signal(); // 唤醒生产者
        } finally {
            lock.unlock();
        }
    }
}