通过实现 Runnable 和扩展 Thread 示例等待并通知

Question

我正在实现逻辑来理解等待和通知工作我发现了一些我无法分析的东西，当我用线程扩展类然后等待和通知按预期工作但是当我实现可运行接口时输出会有所不同

public class AdderThread extends Thread {

int total;

@Override
public void run() {

    synchronized (this) {
        for (int i = 0; i < 1000; i++) {
            total += i;
        }

        notify();
    }

}





public class WaitNotify {

public static void main(String[] args) {

    AdderThread addrTh = new AdderThread();
    addrTh.start();
    // -1243309312

    System.out.println("Total without Wait() " + addrTh.total);


}

}

当实现 Runnable 给我正确的答案时，意味着它正在等待线程完成任务，但是当我使用扩展线程时，它给我的答案为 0，即它没有等待线程完成任务。

public class WaitNotify {

public static void main(String[] args) {

    AdderThread addrTh = new AdderThread();
    addrTh.start();
    // -1243309312

    System.out.println("Total Before Wait " + addrTh.total);
    synchronized (addrTh) {

        try {
            System.out.println("Waiting for Sum...");
            addrTh.wait();
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        System.out.println("Total " + addrTh.total);
    }

}

}

Answer 1

您的新线程可以在主线程调用 `wait() 之前调用 notify()。" 在这种情况下，wait() 调用将永远等待，因为如果其他线程还没有，则 notify() 根本不会做任何事情等待它。

wait() 和 notify() 是低级操作，旨在以非常特定的方式使用：

更多信息请参见Java wait() does not get waked by notify()。

---

实现Runnable的情况和扩展Thread的情况之间的区别在于this在第一种情况下指的是匿名内部类，它指的是@987654328 @object 在后一种情况下。

这很重要，因为线程机器出于自己的目的使用 wait() 和 notify()。因此，如果您的wait() 调用来得太晚而无法被代码中的notify() 调用唤醒，它仍可能被库代码中的notify() 唤醒（例如，当线程终止时）。实现 Runnable 时不会发生这种情况，因为库没有理由通知它。