关于BoundedSemaphore实现中notify与notifyAll使用的疑问

AI 小北

2026-4-16

这个问题问得太到位了！很多刚接触Java并发的同学都会有这个困惑——咱们先把这个BoundedSemaphore的实现逻辑拆明白，再聊notify和notifyAll的选择问题。

首先贴出你提到的实现代码，方便参考：

public class BoundedSemaphore {
  private int signals = 0;
  private int bound   = 0;

  public BoundedSemaphore(int upperBound){
    this.bound = upperBound;
  }

  public synchronized void take() throws InterruptedException{
    while(this.signals == bound) wait();
    this.signals++;
    this.notify();
  }

  public synchronized void release() throws InterruptedException{
    while(this.signals == 0) wait();
    this.signals--;
    this.notify();
  }
}

首先得明确这个类的语义：

take()：相当于生产操作——当缓冲区满（signals == bound）时等待，否则增加信号量（表示多了一个可消费资源），然后唤醒等待线程。
release()：相当于消费操作——当缓冲区空（signals == 0）时等待，否则减少信号量（表示消耗了一个资源），然后唤醒等待线程。

回到你的核心疑问：会不会出现生产者唤醒生产者、消费者唤醒消费者，导致信号丢失？

答案是：在这个特定实现里，完全不会！核心原因是它的两个等待条件是互斥的：

只有当signals == bound（缓冲区满）时，才会有生产者调用take()进入等待；此时signals不可能等于0，所以消费者调用release()时不会进入等待，直接执行操作。
只有当signals == 0（缓冲区空）时，才会有消费者调用release()进入等待；此时signals不可能等于bound，所以生产者调用take()时不会进入等待，直接执行操作。

换句话说，这个对象的等待队列里永远只会有同一种类型的线程：要么全是等着生产的生产者，要么全是等着消费的消费者，绝不会混合出现。

这时候用notify()就足够安全：

当消费者执行release()后调用notify()，唤醒的一定是某个等待的生产者，这个生产者醒来后会发现signals < bound，能顺利执行生产操作；如果生产后缓冲区又满了，它调用的notify()会唤醒另一个生产者，但那个生产者醒来后会发现signals == bound，继续等待——这完全符合逻辑，没有信号丢失。
反过来，生产者执行take()后调用notify()，唤醒的一定是某个等待的消费者，同样不会有问题。

那什么时候必须用notifyAll()？当等待队列里可能存在不同等待条件的线程时。比如直接实现生产者消费者的缓冲区类（而非用这种信号量封装），类里同时有“等待缓冲区非空”的消费者和“等待缓冲区非满”的生产者，这时候用notify()就可能唤醒错误类型的线程，导致真正需要被唤醒的线程一直等待，出现信号丢失——这种场景下notifyAll()才是更安全的选择，因为它会唤醒所有等待线程，让它们各自检查自己的等待条件。

总结一下：这个BoundedSemaphore实现里用notify()是合理的，因为它的等待条件互斥，不会出现唤醒错误线程导致信号丢失的情况；但如果是多条件等待的复杂场景，notifyAll()才是必要的。

备注：内容来源于stack exchange，提问作者xyzcoder