如何在 JAVA 中通知类中的所有线程？

Question

我可以创建一个静态函数来通知在此类的任何实例中等待的所有线程吗？

（这里的逻辑是我有队列中有线程在等待，因为它们是空的，我想在调用这个函数时完成程序的运行）

queue = new Vector<T>();

 public synchronized T extract(){
        while(queue.isEmpty())
            try {
                this.wait();
                if(!active) {return null;}
            }catch(InterruptedException e) {}
        T t = queue.elementAt(0);
        queue.remove(0);
        return t;
}

这是提取方法。 当队列为空时，线程进入等待状态。 我想让布尔值“激活”为 false 并 notifyAll。

那我会确保线程不会再调用这个方法

Answer 1

这里的逻辑是我的队列中有线程在等待，因为它们是空的，我想在调用这个函数时完成程序的运行

IMO，对您的问题更好的解决方案是继续使用每个实例的锁，但在需要关闭所有队列时向每个队列提交一个毒丸。

final T poison_pill = new T(...);

public synchronized T extract(){
    while(queue.isEmpty())
        try {
            this.wait();
        }catch(InterruptedException e) {}
    T t = queue.elementAt(0);
    if (t == poison_pill) {
        ...My preference would be to raise an exception here, but...
        return NULL;              // ...this was in your original example.
    }
    else {
        queue.remove(0);
        return t;
    }
}

---

如果您真的希望能够同时notify() 所有不同的实例，那么您必须将它们全部设置为wait() 在同一个全局锁定对象上.

final Object global_lock = new Object();

public T extract(){
    synchronized(global_lock) {
        while(queue.isEmpty())
            try {
                global_lock.wait();
                if(!active) {return null;}
            }catch(InterruptedException e) {}
        T t = queue.elementAt(0);
        queue.remove(0);
        return t;
    }
}

然后在其他地方：

synchronized(lock) {
    ...
    global_lock.notifyAll();
}