wait（）不强制线程等待？

Question

我有两个线程t0和t1，分别在代码段Run_0和Run1中列出了runnables。我想要做的是，当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

wait，notify和notifyAll应内部​​块。你有一个notify是外面：

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

Answer 2

从javadocs（重点煤矿）：

导致当前线程等待，直到其他线程调用notify()方法或为notifyAll()方法这个对象。

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

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类不是Run_0类t1.wait()。也许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对象。