Java 通知线程

Question

我尝试实现线程wait（）和notify（），但是通知方法不起作用，你能帮我吗？我希望读者线程尝试从他的消息框中读取;如果消息框为空，则读取器将等待编写器完成作业。但是在通知操作之后，读者仍然等待并且什么都不做，作者继续他的工作。这是我的代码（其他自定义对象工作正常）：

    public class TrheadTEST {
    private static class AgentThred implements Runnable {    
        private final  String name;
        private final String category;
        private final PersonalAgentID agentID; // it has name and category 
        private AgentThred obiettivo; 
        private Thread trd; // i try to call notify for a specific thread.
        public MessageBox msgx; // each thread has a messagebox. Agent can read only her own messagebox        
        public AgentThred(String nam, String cat){
            this.name = nam;
            this.category = cat;
            this.agentID = new PersonalAgentID(this.name, this.category);
            this.msgx.setOwner(this.agentID);            
            this.msgx = new MessageBox();
        }
        public void setObj(AgentThred i) {
            this.obiettivo = i;
        }
        public void setThread(Thread i) {
            this.trd = i;
        }
        @Override
        synchronized  public void run() { 
        {
//set a message to send
        if(this.name == "Mercoledi"){
            while(true){
                // writer write a message in reader messagebox
                System.out.println("writer wrote");
                notifyAll();   //wake up the reader--doesn't work
               //sleep(500)
            }
        }
        else
            while(true){
                if(this.msgx.imEmpty()){ // if reader messagebox is empty
                    System.out.println("reader can't read");
                    wait(); //wait until writer put a message in the reader message box
                }
                else{
                    System.out.println("reader can read ");
                    //read the message
                }
            }
    }
}
}
}
public static void main() {
    AgentThred agt1 = null;
    AgentThred agt2 = null;
     MessageBox msg = new MessageBox();
    }
    agt1 = new AgentThred("Mercoledi","Addams");
    agt2 = new AgentThred("Mano","Addams");
    Thread t1 = new Thread(agt1);
    Thread t2 = new Thread(agt2);
    t2.start();
    t1.start();
//I need a join here? 
}
}

Answer 1

要将agt2从等待中唤醒，您需要在与用于等待的对象相同的对象上调用notifyAll。在您的情况下，agt2等待this.wait()，因此您需要致电agt2.notifyAll()将其唤醒。

另请注意，不建议将字符串与 == 进行比较，即使它恰好适用于您的情况。

因此，您可以定义一个：

private static final Object waiter = new Object();

并致电：

synchronized(waiter) {
  waiter.wait();
  //or
  waiter.invokeAll();`
}

Answer 2

您需要在两者之间有一个公共对象，您可以在该对象上等待并通知。现在，您正在两个不同线程的此实例上同步，并说this.wait和this.notify，因此它不起作用。

要使等待和通知正常工作，您需要在同一对象上获取互斥锁。有关详细信息，请参阅此处。

wait Causes the current thread to wait until another thread invokes the notify() method or the notifyAll() method for this object. In other words, this method behaves exactly as if it simply performs the call wait(0).
The current thread must own this object's monitor. The thread releases ownership of this monitor and waits until another thread notifies threads waiting on this object's monitor to wake up either through a call to the notify method or the notifyAll method. The thread then waits until it can re-obtain ownership of the monitor and resumes execution.

您可以尝试将公共对象传递给单个线程，例如字符串并在同一线程上进行同步，并使用该对象调用等待和通知。 比如：

//thread1
synchronize(myString) {
    myString.wait();
}
//thread2
synchronize(myString) {
    myString.notifyAll();
}

Answer 3

您正在传递消息，因此请尝试使用 java.util.concurrent 类。 创建一个两个线程通用的 LinkedBlockingQueue，并使用 put（） 和 take（） 方法来传递消息。

这样可以避免在没有消息可供读取或没有空间可用于放置消息时使用同步和阻止。 如果这不是您所需要的，不同的类会给出不同的行为。