Warten auf Bedingung in Java

Wait() wird immer weiter, weil Sie nie aufrufen, notify().

Könnten Sie warten in der Warteschlange und den Anruf benachrichtigt, wenn Sie möchten, dass der wartende thread zu wakeup. Um dies zu tun würden Sie ändern Produzent zu Lesen:

 synchronisiert (qq) { 
while (qq.size() > 0) 
qq.wait(); 

System.aus.println("neu Hinzufügen"); 
qq.put("Wert 1"); 
qq.put("Wert 2"); 
qq.put("Wert 3"); 
qq.put("Wert 4"); 
} 

Und ändern Verbraucher zu Lesen:

 while(true) { 
synchronisiert (qq) { 
System.aus.println ("" + qq.nehmen() + ". "+ String.valueOf(qq.size()) + "left"); 
qq.notify(); 
} 
Thread.sleep(1000); 
} 

Als Steve sagt in seiner Antwort, Sie könnte auch mit wait() in der consumer-thread, so kann es warten, bis es etwas in die Liste, anstatt zu schlafen. So würde der code geworden:

import java.util.gleichzeitige.BlockingQueue; 
import java.util.gleichzeitige.LinkedBlockingQueue; 

public class SO { 
public String test; 
public String[] Liste = new String[] { test }; 

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

öffentlichkeit, SO() { 
go(); 
} 

BlockingQueue qq = new LinkedBlockingQueue(); 

class Produzent implements Runnable { 
public void run() { 
try { 
while (true) { 
synchronisiert (qq) { 
if (!qq.isEmpty()) { 
qq.wait(); 
} 

System.aus.println("neu Hinzufügen"); 
qq.put("Wert 1"); 
qq.put("Wert 2"); 
qq.put("Wert 3"); 
qq.put("Wert 4"); 
qq.notify(); 
} 
} 
} catch (InterruptedException ex) { 
} 
} 
} 

class Verbraucher implements Runnable { 
public void run() { 
try { 
while (true) { 
synchronisiert (qq) { 
System.aus.println ("" + qq.nehmen() + ". " 
+ String.valueOf(qq.size()) + "left"); 
wenn (qq.isEmpty()) { 
qq.notify(); 
qq.wait(); 
} 
} 
} 
} catch (InterruptedException ex) { 
} 
} 
} 

public void go() { 
Produzent p = new Produzent(); 
Consumer c = new Consumer(); 

new Thread(p).start(); 
new Thread(c).start(); 
} 
} 

InformationsquelleAutor Richard Miskin

Sice, Sie sind mit BlockingQueue Sie nicht verwenden synchronized, weil BlockingQueue ist sychronized standardmäßig. Wenn Sie möchten, um die Synchronisierung zu verwenden, als Sie sollten synchronisieren durch das gleiche Objekt:

 synchronized(theSameObjectInstance) {
    while (true) {                        
        while (qq.size() > 0)
            theSameObjectInstance.wait();                            

        System.out.println("Adding new");
        qq.put("Value 1");
        ...

        theSameObjectInstance.notifyAll();
    }
 }

und Verbraucher Methode sollte eingewickelt in synchronized(theSameObjectInstance) um Benachrichtigung erhalten, sollten die Verbraucher auch "warten" irgendwo z.B. bei qq ist leer.

InformationsquelleAutor Steve