// Konsument.java
// -------------------------------------------------------------
class Konsument extends Thread {
int artikel = 0;
Lager lag = null;
Konsument(Lager lag) {
this.lag = lag;
}
public void run() {
while(true) {
while(lag.z == -1); // warten <===== !!!
artikel = lag.get();
if(artikel == -1) break; // Endesignal
konsumiere(artikel);
}
int i=lag.z + 1; // Restverbrauch
while(true) {
i--;
if(i==-1) break;
artikel = lag.get();
konsumiere(artikel);
}
}
void konsumiere(int artikel) {
System.out.println(" Konsumiere " + artikel);
}
}