wait() 不强制线程等待？

Question

我有两个线程 t0 和 t1，它们分别在下面的代码部分 Run_0 和 Run1 中发布。我想要做的是，当 t0 正在写入或执行持续 7 秒的任务时，t1 应该等待。当 7 秒过去，应通知 t1 继续工作。我尝试使用 wait() 和 notify() 来做到这一点，但在运行时我希望 t0 启动但控制台只显示“T1 正在工作”并且 t0 没有打印任何内容，就好像它没有打印一样 开始

请告诉我为什么会发生这种行为。

代码：

public static void main(String[] args) {

    t0 = new Thread(new Run_0());
    t1 = new Thread(new Run_1());

    t0.start();
    t1.start();
}

private static class Run_0 implements Runnable {

    public void run() {
        // TODO Auto-generated method stub

        while (true) {
            long startTime = TimeUtils.getTSSec();
            synchronized (t1) {
                try {
                    t1.wait();
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }

            System.out.println("T0 is writing");
            //simulate doing some work
            while( (TimeUtils.getTSSec()-startTime) <= 7) {

            }
            System.out.println("T0 finished writing");

            synchronized (t1) {
                t1.notify();
            }

            startTime = TimeUtils.getTSSec();

            while( (TimeUtils.getTSSec()-startTime) <= 7) {

            }
        }

    }

}

private static class Run_1 implements Runnable {

    public void run() {
        // TODO Auto-generated method stub

        while(true) {

            System.out.println("T1 is working");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }

}

Answer 1

来自javadocs（强调我的）：

使当前线程等到另一个线程为此对象调用notify() 方法或notifyAll() 方法。

您的代码导致t0 等待，而不是t1。

Answer 2

wait、notify 和 notifyAll 应该在 synchronized 块内。你有一个notify 在它外面：

        t1.notify(); // <-------
        startTime = TimeUtils.getTSSec();

Answer 3

控制台只显示“T1 正在工作”，而 t0 什么也不打印，就好像它没有启动一样

是的，因为Run_0.run() 中的第一件事是t1.wait();。那是在等待有人打电话给t1.notify() 或t1.notifyAll()。我看没人这么叫。

当线程在对象上调用wait() 时，它会导致线程等待对象上的监视器得到通知。一个线程不会导致另一个线程等待。它只能等待自己。

重要的是要意识到您正在对恰好是一个线程的t1 对象进行同步、等待和通知。两个线程之间共享的任何对象都可以工作，由于我们对锁定 t0 或 t1 线程对象感到困惑，因此您应该创建一个最终的锁定对象并锁定它：

private final Object lock = new Object();

t0 正在写入或执行其持续 7 秒的任务，t1 应该在等待。

所以听起来你应该在Run_1 类中使用t1.wait() 而不是Run_0 类。也许Run_0 应该这样做：

// much better way to simulate time passing instead of a spin loop
Thread.sleep(7000);
System.out.println("T0 finished writing");
synchronized (lock) {
    lock.notify();
}

然后在Run_1 你会做类似的事情：

synchronized (lock) {
    lock.wait();
}
System.out.println("T1 is working");

请注意，我使用的是常见的 lock 对象。