Java notify() wird vor wait() aufgerufen

Question

Ist es nicht möglich, dass notify() in einem anderen Thread vor dem wait() in einem Thread aufgerufen wird? Es passiert mit mir.

Ein Client fordert einen Wert von einem Ziel an und wartet auf eine Ergebnisvariable RV. Falls das Ziel der Client selbst ist, aktualisiere ich RV mit dem korrekten Ergebnis und rufe notify() auf RV in einem anderen Thread auf.

class EMU { 

    ResultVar RV; 
    Address my_address; 

    ResultVar findValue(String key) { 
    String tgt = findTarget(key); 
    sendRequest(tgt, key); 
    synchronized(RV) { 
     RV.wait(); 
    } 

    return RV; 
    } 

    Runnable Server = new Runnable() { 
    public void run() { 
     //code to receive connections. Assume object of type Request is read from the stream. 
     Request r = (Request) ois.readObject(); 
     if(r.requesterAddr.compareTo(my_address) == 0) { 
     String val = findVal(key); 
     RV.putVal(val); 
     synchronized(RV){ 
      RV.notify(); 
     } 
     } 
    } 
    }; 
} 

Das Problem ist, dass, bevor der Antragsteller alle „Networking“ (sendReqest in dem obigen Beispiel) mit sich selbst abgeschlossen ist, wird das Ergebnis in der Ergebnisvariablen aktualisiert. Wenn der Requester-Thread nun wait() aufruft, wird das Programm nicht fortgesetzt, da notify bereits aufgerufen wurde.

Wie können wir das verhindern?

Answer 1

Sie einige Flag überprüfen, bevor (in einer Schleife) wartet, finden Sie in der Anleitung: http://docs.oracle.com/javase/tutorial/essential/concurrency/guardmeth.html

Answer 2

Nichts hält Sie notify auf einem Objekt aufrufen, die von einem anderen Thread ed nicht wait sein wird.

Es klingt wie, was Sie wollen, ist eine Wartezeit nur, wenn eine Bedingung erfüllt ist. Zum Beispiel:

synchronized (results) { 
    while (!results.hasResults()) { 
     // no results yet; wait for them 
     try { 
      results.wait(); 
     } catch (InterruptedException ie) { /* ignore */ } 
    } 
} 

Answer 3

Ich würde dringend empfehlen, das Rad nicht neu zu erfinden.

Die Java-Schnittstelle Future wurde für Ergebnisse entwickelt, die möglicherweise erst später eintreffen, und die Klasse FutureTask implementiert diese Schnittstelle.

Lassen Sie den ersten Thread Zugriff auf die Zukunft und erhalten Sie den zweiten Thread, um die FutureTask auszuführen, und all das Zeug wird für Sie behandelt. Sie erhalten auch Timeout-Unterstützung kostenlos.

Answer 4

Verwenden einige Zustand vor() warten werde und stellen Sie sicher, dass diese Bedingung Thread-sicher ist :)

class EMU{ 
    ResultVar RV; 
    Address my_address; 
    volatile boolean condition = true; 

    ResultVar findValue(String key){ 
     String tgt = findTarget(key); 
     sendRequest(tgt, key); 
     synchronized(RV){ 
      while(condition == true) 
      { 
       RV.wait(); 
      } 
     } 
     return RV; 
    } 

    Runnable Server = new Runnable(){ 
     public void run(){ 
      //code to receive connections. Assume object of type Request is read from the stream. 
      Request r = (Request) ois.readObject(); 
      if(r.requesterAddr.compareTo(my_address) == 0){ 
       String val = findVal(key); 
       RV.putVal(val); 
       synchronized(RV){ 
        condition = false; 
        RV.notify(); 
       } 
      } 
     } 

    };