Problem Thread und Monitoring

[Godric]

Hi, ich habe folgendes Problem: obwohl alle abfragen korrekt zu sein scheinen, werden threads die ich vorher auf wait gesetzt habe, durch notify, doer notifyAll nicht fortgesetzt. Für eine Richtigkeit der Abfragen kann ich garantieren, da das Programm richtig ausgeführt wird, wenn ich die Threads nicht vorerst stoppe sondern in einer whileschleife gefangen halte. Dies ist jedoch für mich inakzeptabel, da ich möglichst effizient programmieren möchte. Hier erstmal der Code:

class Sau{
	private int geschlecht, anzahl;
	public Sau(){
		geschlecht=0;
		anzahl=0;
	}
	public int getGeschlecht(){
		return geschlecht;
	}
	public int getAnzahl(){
		return anzahl;
	}
	public void setGeschlecht(int x){
		geschlecht=x;
	}
	public void incAnzahl(){
		anzahl=anzahl + 1;
	}
	public void decAnzahl(){
		anzahl=anzahl-1;
	}
}
class Pers extends Thread{
	private String name;
	private int geschlecht,sleepTime;
	private Sau sauna;
	public Pers(String n, int g, int s, Sau sau){
		name=n;
		geschlecht=g;
		sleepTime=s;
		sauna=sau;
	}
	public void run(){
		System.out.println("Anfang "+name);
		synchronized(this){
			while((sauna.getGeschlecht()!=0) && (sauna.getGeschlecht()!=geschlecht)){
				
					
				
				/*try{
					wait();
				}catch(InterruptedException e){
					
				}*/
			}
			System.out.println("In Sauna eingetreten! "+name);
			if(sauna.getAnzahl()==0)
				sauna.setGeschlecht(geschlecht);
			sauna.incAnzahl();
			
		}
		try {
			sleep(sleepTime);
		} catch (InterruptedException e) {
			
		}
		System.out.println("Zeit in Sauna geniessen "+name);
		synchronized(this){
			sauna.decAnzahl();
			if(sauna.getAnzahl()==0)
				sauna.setGeschlecht(0);
			//notifyAll();
			System.out.println("Sauna verlassen "+name);
			System.out.println(sauna.getGeschlecht());
		}
	}
}
public class SaunaSim {
	public static void main(String [] args){
		Sau s=new Sau();
		new Pers("1",1,0,s).start();
		new Pers("2",2,0,s).start();
		new Pers("3",1,0,s).start();
		new Pers("4",2,0,s).start();
		new Pers("5",1,0,s).start();
	}

}

Ich bin neu hier, hoffe habe mich an die Regeln gehalten und im richtigen Abschnitt des Forums gepostet. Ich möchte mich bereits im vorraus bedanken. Falls meine Angaben zu unprägnant waren, stellt bitte Fragen.
MfG,
Christoph

 

[Michael...]

Du musst die wait Methode an dem Objekt aufrufen auf das der aktuelle Thread warten soll (in Deinem Fall die Sauna) und das Objekt muss dann notifyAll() aufrufen, wenn die Thread wieder drauf zu greifen sollen (z.B. wenn eine Person die Sauna verlässt)

Folgende Zeilen bringen Dir nicht viel, da sich das synchronized auf die Person bezieht:

[JAVA=35]
synchronized(this){
[/code][JAVA=58]
synchronized(this){
[/code]

Viel mehr solltest Du die Sauna bzw. ein paar ihrer Methoden synchronisieren.

 

[Godric]

vielen dank, ich werde das sofort mal testen!!

 

[Godric]

Läuft wunderbar! danke nochmal. Code sieht jetzt so aus:

class Sau{
	private int anzahl, geschlecht;
	public Sau(){
		anzahl=0;
		geschlecht=0;
	}
	public int getAnzahl(){
		return anzahl;
	}
	public int getGeschlecht(){
		return geschlecht;
	}
	public void incAnzahl(){
		anzahl++;
	}
	public void decAnzahl(){
		anzahl--;
	}
	public void setGeschlecht(int x){
		geschlecht=x;
	}
	synchronized public void eintreten(Pers p){
		while(this.getGeschlecht()!=0 && this.getGeschlecht()!=p.getGeschlecht() ){
			try{
				wait();
			}catch(InterruptedException e){
				
			}
		}
		if(getAnzahl()==0)
			setGeschlecht(p.getGeschlecht());
		incAnzahl();
	}
	synchronized public void austreten(Pers p){
		decAnzahl();
		if(getAnzahl()==0){
			setGeschlecht(0);
			notifyAll();
		}
	}
	
	
}
class Pers extends Thread{
	private String name;
	private int geschlecht,sleepTime;
	private Sau sauna;
	public Pers(String n, int g, int s, Sau ss){
		name=n;
		geschlecht=g;
		sleepTime=s;
		sauna=ss;
	}
	public int getGeschlecht(){
		return geschlecht;
	}
	public void run() {
		System.out.println("Anfang "+name+" " +geschlecht);
		sauna.eintreten(this);
		System.out.println("Eingetreten "+name+" " +geschlecht);
		try{
			sleep(sleepTime);
		}catch(InterruptedException e){
			
		}
		System.out.println("Ausgeruht "+name+" " +geschlecht);
		sauna.austreten(this);
		System.out.println("Ausgetreten "+name+" " +geschlecht);
		
		
	}
	
			
			
		
	
	
}
public class SaunaSim{
	public static void main(String [] args){
		Sau s=new Sau();
		new Pers("1",1,0,s).start();
		new Pers("2",2,0,s).start();
		new Pers("3",1,0,s).start();
		new Pers("4",2,0,s).start();
		new Pers("5",1,0,s).start();
		
	}
}