Java等待/通知-不唤醒线程

Question

我想做一个小练习来习惯等待/通知。我想做的是简单地启动一个线程，然后用等待让它进入睡眠状态，用通知唤醒它，多次。

我的代码是：

public class Simple{
    static final Thread mainThread = Thread.currentThread();

    public static void main(String[] args) throws InterruptedException {
        PrintThread printer = new PrintThread(0);
        printer.start();

        synchronized (mainThread){
            System.out.println("main sleeping while waiting for printer to be started");
            mainThread.wait();
            System.out.println("main woke up");


            for (int i = 0; i < 1000; i++) {
                synchronized (printer){
                    System.out.println("added num "+i);
                    printer.numToPrint = i;
                    System.out.println("main waking up printer");
                    printer.notifyAll();
                    System.out.println("main sleeping");
                    mainThread.wait();
                    System.out.println("main woke up");
                }
            }

        }

    }
}

class PrintThread extends Thread{
    public int numToPrint = -1;

    public PrintThread(int numToPrint){
        this.numToPrint = numToPrint;
    }

    @Override
    public synchronized void run() {
        System.out.println("printer started");
        while (true){
            try {
                synchronized (Simple.mainThread){
                    System.out.println("printer waking up main");
                    Simple.mainThread.notifyAll();
                }
                System.out.println("printer sleeping");
                wait();
                System.out.println("printer woke up");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("printing num "+numToPrint);
        }
    }

}

我希望这会是这样

main sleeping while waiting for printer to be started
printer started
printer waking up main
printer sleeping
main woke up
added num 0
main waking up printer
main sleeping
printer woke up
printing num 0
printer waking up main
printer sleeping
main woke up
added num 1
...

相反，这样做：

main sleeping while waiting for printer to be started
printer started
printer waking up main
printer sleeping
main woke up
added num 0
main waking up printer
main sleeping

所以。。。通知似乎没有唤醒打印机线程？

这不应该是一个死锁，因为通过等待，我释放了所有的锁，所以主服务器不应该有任何对打印机的锁，打印机应该能够唤醒并打印。

我做错了什么？

Answer 1

属性：调用等待（）释放锁（它正在监控的锁）并进入等待状态。它在同一对象上等待通知（）或通知所有（）。一旦通知（）或通知所有（）并在CPU中进行调度，它就会在恢复之前再次获取锁。

当你第一次在main方法中“同步（mainThread）”时，它基本上锁定了“mainThread”类对象。当调用 mainThread.wait（） 时，mainThread 进入等待状态（等待某人在 mainThread 类对象上调用 notify 或 notifyAll）。

此时，PrintThread可能会占用CPU。这是当“synchronized（Simple.mainThread）”被调度并锁定“Simple.minThread”并通知所有等待“Simple.mainThread”的线程时。在这个块完成后，PrintThread释放“Simple.mainThread”锁。

此时，主线程将再次尝试获取“主线程”上的锁，然后从调用等待的位置恢复。由于此时未获取“mainThread”锁，所以主线程获取锁并打印“main waked up”。

现在，这里遇到了for循环。记住：这里已经获取了“mainThread”类Object的锁。

现在在for循环内部，它获取“打印机”对象的锁。做一些计算，调用“printer.notify所有（）”，所有等待“打印机”对象的线程都将被通知。

**这里要记住的一点是：由于代码光标仍在“同步（打印机）”内，因此“打印机”对象的锁定尚未释放。**

继续前进，打印“main sleeping”，然后调用“mainThread.wait（）”。这尝试在已经获取的“mainThread”上获取锁（上面提到“记住：”在块中）并卡住，因为此后没有线程在“mainThread”上通知，并且“同步（打印机）”块永远不会结束，即即使在调用 NotifyAll（） 之后，“打印机”对象的锁定也永远不会释放。

尝试在开始时的 Main 方法中添加以下代码，以测试上述场景。

synchronized (mainThread) {
            synchronized (printer){
                System.out.println("Before");
                mainThread.wait();
                System.out.println("After");
            }

解决方案：关闭“printer.notifyAll（）”之后的“synchronized（printer）”块，以便在通知之后和获取“mainThread”之前释放“printer”锁。

Answer 2

很可能您的 notifyAll（） 调用是在打印调用 wait（） 再次之前调用的。问题在于您依赖于等待和通知所有调用都按照您希望的顺序发生。这是两个不同的执行线程，所以当然不能保证这一点，因此你得到了你所拥有的。

实现此目的的更好方法是创建一个公共的第三个共享对象，两个线程都可以获取锁定。这将在两个线程等待访问此对象时同步它们。

另外，您应该阅读 Javadocs for Thread.wait、notify和 notifyAll。如果你这样做了，你会发现你永远不应该在线程上调用这些方法，因为它们用于执行thread.join（不仅如此，我的“名声”是我相信这是我多年前的错误请求，当这不在JavaDoc中时，导致它被添加到Javadoc中。可能是其他人，但它发生在我要求之后:)）