Java锁与条件实现等待唤醒机制

import java.util.LinkedList;
import java.util.concurrent.locks.*;

public class ProducerConsumer {
    private final LinkedList buffer = new LinkedList<>();
    private final int MAX_SIZE = 5;
    private final Lock lock = new ReentrantLock();
    private final Condition notFull = lock.newCondition();
    private final Condition notEmpty = lock.newCondition();

    public void produce(String data) throws InterruptedException {
        lock.lock();
        try {
            while (buffer.size() == MAX_SIZE) {
                System.out.println("缓冲区满，生产者等待...");
                notFull.await();
            }
            buffer.add(data);
            System.out.println("生产：" + data);
            notEmpty.signal(); // 唤醒消费者
        } finally {
            lock.unlock();
        }
    }

    public String consume() throws InterruptedException {
        lock.lock();
        try {
            while (buffer.isEmpty()) {
                System.out.println("缓冲区空，消费者等待...");
                notEmpty.await();
            }
            String data = buffer.removeFirst();
            System.out.println("消费：" + data);
            notFull.signal(); // 唤醒生产者
            return data;
        } finally {
            lock.unlock();
        }
    }
}