Java中 Condition 怎么实现多生产者多消费者的环形队列 Buffer 阻塞控制-java教程-PHP中文网

Java中用ReentrantLock+两个Condition（notFull、notEmpty）和计数器实现线程安全环形缓冲区：生产者put时满则await notFull，写入后signal notEmpty；消费者take时空则await notEmpty，读取后signal notFull；所有状态操作均在锁内，用while防虚假唤醒。

java中 condition 怎么实现多生产者多消费者的环形队列 buffer 阻塞控制

Java 中用 Condition 实现多生产者多消费者的环形缓冲区（Ring Buffer），核心是借助 ReentrantLock + 多个 Condition 实现精准的阻塞/唤醒控制：一个条件变量管“非满”，一个管“非空”，避免 notifyAll() 的无效唤醒。

环形缓冲区的基本结构设计

定义固定大小数组，维护两个指针：head（消费者读位置）、tail（生产者写位置）。容量为 N 时，实际可用空间为 N-1（留一个空位区分满/空），或用额外计数器。推荐用计数器方式更直观：

buffer：Object[] 或泛型数组
lock：ReentrantLock 实例
notFull：Condition，当缓冲区满时，生产者 await
notEmpty：Condition，当缓冲区空时，消费者 await
count：原子整数或受锁保护的 int，记录当前元素个数

生产者线程的 put 操作（线程安全 + 阻塞）

生产者调用 put() 时，先加锁，检查是否已满；满则 notFull.await() 挂起，被唤醒后继续尝试写入。写完后通知消费者（notEmpty.signal()）：

public void put(T item) throws InterruptedException {
    lock.lock();
    try {
        while (count == buffer.length) {
            notFull.await(); // 等待有空位
        }
        buffer[tail] = item;
        tail = (tail + 1) % buffer.length;
        count++;
        notEmpty.signal(); // 唤醒至少一个消费者
    } finally {
        lock.unlock();
    }
}

注意用 while 而非 if —— 防止虚假唤醒或多个生产者竞争下再次变满。

消费者线程的 take 操作（线程安全 + 阻塞）

消费者调用 take()，加锁后检查是否为空；空则 notEmpty.await()，唤醒后读取、更新指针、通知生产者：

Java注释规范Skills

当用户要求为 Java 代码添加注释、修改注释、审查注释、整理注释格式，或要求按照代码注释规范处理 Java 文件时，使用本技能。本技能用于统一生成和维护 Java 类注释模板、按 Git 对比 release 判断版本号、补充每行代码上方中文块注释、调整注释空行规则，并保持 Java 文件 UTF-8 无 BOM 编码。典型触发场景包括：补充类注释、更新 @version、检查 @author 来源、整理行尾注释、把注释放到代码上一行、检查注释是否符合规范、构建前检查 Java 注释风格。

下载

public T take() throws InterruptedException {
    lock.lock();
    try {
        while (count == 0) {
            notEmpty.await(); // 等待有数据
        }
        T item = (T) buffer[head];
        buffer[head] = null; // 避免内存泄漏（对引用类型）
        head = (head + 1) % buffer.length;
        count--;
        notFull.signal(); // 唤醒至少一个生产者
        return item;
    } finally {
        lock.unlock();
    }
}

signal() 而非 signalAll() 即可，因只需唤醒一个对应角色线程，减少上下文切换开销。