Java等待/通知不起作用

Question

所以我一直在研究一个简单的等待/通知的例子在Java中，由于某些原因，我一直无法让它正常运行。如果有人能够看到可能是什么问题，将非常感谢！

public class ThreadDemonstration 
{ 
private String str = null; 

Thread stringCreator = new Thread(new Runnable() 
{ 
    public void run() 
    {   
     synchronized(this) 
     {    
      str = "I have text"; 
      notify();    
     } 
    } 
}); 

private Thread stringUser = new Thread(new Runnable() 
{ 
    public void run() 
    { 
     synchronized(this) 
     { 
      if(str == null) 
      {     
       try { 
        System.out.println("str is null, I need help from stringCreator"); 
        wait(); 
        System.out.println(str); 
       } 
       catch (InterruptedException e) 
       { 
        e.printStackTrace(); 
       } 
      } 

     } 
    } 
}); 

public static void main (String [] args) 
{ 
    ThreadDemonstration td = new ThreadDemonstration(); 
    td.stringUser.start(); 
    td.stringCreator.start(); 
} 

}

我的电流输出为： str是空的，我需要从stringCreator

帮助，所以出于某种原因线程stringCreator没有醒stringUser还是我失去了完全是另一回事？

谢谢！

Answer 1

您的区块为​​，覆盖不同的物件。他们应该是​​过公共对象，例如下面的monitor对象：

public class ThreadDemonstration 
{ 
private String str = null; 
    private final Object monitor = new Object(); 

Thread stringCreator = new Thread(new Runnable() 
{ 
    public void run() 
    {   
     synchronized(monitor) 
     {    
      str = "I have text"; 
      monitor.notify();    
     } 
    } 
}); 

private Thread stringUser = new Thread(new Runnable() 
{ 
    public void run() 
    { 
     synchronized(monitor) 
     { 
      while(str == null) //changed from if to while. This allows you to wait again if the thread gets woken up by something other than the appropriate notify. 
      {     
       try { 
        System.out.println("str is null, I need help from stringCreator"); 
        monitor.wait(); 
        //removed print statement from here 
       } 
       catch (InterruptedException e) 
       { 
        e.printStackTrace(); 
       } 
      } 
      System.out.println(str); //added print statement here. str is guaranteed to not be null here. 
     } 
    } 
}); 

为了避免创建同步单独的对象，可以使用例如synchronized(ThreadDemonstration.this)或synchronized(ThreadDemonstration.class)。

Answer 2

试试这个：

private Thread stringUser = new Thread(new Runnable() { 
    //----- 

    System.out.println("str is null, I need help from stringCreator"); 
    notify(); 
    wait(100); 
    System.out.println(str); 

    //---- 
}); 

Answer 3

您需要使用相同的实例的wait和notify以便为它工作。由于您创建了两个不同的对象（Runnable的两个实例），它将无法工作。我已经写了一个简单的例子，它使用两个不同的类，使用主类的内部锁的实例。你也可以为我们设置一个“虚拟对象”（Object lock = new Object）。

public class ThreadDemonstration { 

    private static String text; 

    public ThreadDemonstration(){ 
     Thread user = new Thread(new StringUser(this)); 
     Thread creator = new Thread(new StringCreator(this)); 
     user.start(); 
     try { 
      Thread.sleep(1000); 
     } catch (InterruptedException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 
     creator.start(); 
    } 

    public class StringCreator implements Runnable{ 

     private Object lock; 

     StringCreator(Object lock){ 
      this.lock = lock; 
     } 

     @Override 
     public void run() { 
      synchronized(lock){ 
       text = "Yeeeehaaaaa"; 
       lock.notify(); 
      } 

     } 

    } 

    public class StringUser implements Runnable{ 

     private Object lock; 

     StringUser(Object lock){ 
      this.lock = lock; 
     } 

     @Override 
     public void run() { 

      synchronized(lock){ 

       if((text == null)){ 
        System.out.println("I need help!"); 
        try { 
         lock.wait(); 
        } catch (InterruptedException e) { 
         e.printStackTrace(); 
        } 
       } 
       System.out.println(text); 
      } 

     } 

    } 

    public static void main(String[] args){ 
     new ThreadDemonstration(); 
    } 

}