JAVA- Prüfungsaufgabe über Thread

[Guest]

Hallo zusammen,
ich sitzt gerade an einer JAVA-Programieraufgabe über Threads und komme einfach nicht klar damit.

Aufgabe:
Schreiben Sie ein Applet Ziehbrunnen , das je ein Thread mit Name pumpe und verteiler erzeugt. Dies sind Objekte der Klasse Schoepfer(Schoepfer hat die Fähigkeit, Funktion von pume und verteiler auszuführen.

Das Applet verwaltet den Wassertrog(int). pumpe schüttet im Sek. -Takt Wasser in den Trog(zwischen 0 und 20 Liter(Random)) und verteiler nimmt zufallsmenge zwischen 0 und 20 liter. Wenn weniger im Wassertrog vorhanden, wartet der verteiler bis die Pumpe genug Wasser eingefüllt hat. Nach oben ist die Wassermenge unbegrenzt. Der Wassertrog darf überlauffen.

Mein Problem ist ja nun, dass ich hier das Konsumenten/Produzenten in einem Thread-Objekte stehen muss. Wie weiss nun das applet, welches der Konsument und welches der Produzent sind?

Wäre echt froh um Hilfe. Steh wirklich an
Mit freundlichen Grüssen
Manuel Miklo

 

[SlaterB]

> Wie weiss nun das applet, welches der Konsument und welches der Produzent sind?

Programmieren ist doch kein Rätselraten,
du hast doch Exemplarvariablen wie

Thread pumpe = ..;
Thread verteiler = ..;

und greifst auf diese Objekte mit den Variablen zu, wie soll man da vergessen, wer wer ist?

 

[jPat]

Mein Problem ist ja nun, dass ich hier das Konsumenten/Produzenten in einem Thread-Objekte stehen muss. Wie weiss nun das applet, welches der Konsument und welches der Produzent sind?

das je ein Thread mit Name pumpe und verteiler erzeugt

Meinst du, dass die Aufgabe nicht so verstanden wird, wie sie gestellt wurde ??

 

[Guest]

Hallo, ich(Gast) bin es noch einmal. Werd mich jedoch bald Registrieren...Super Forum...
Ich habe mich nochmal hingesetzt an die Aufgabe. Das ist bis jetzt rausgekommen.
Kann sich den Code mal ein Profi anschauen und mir vielleicht weiterhelfen? Irgendwas mit den Threads geht einfach noch schief....:-(

(1. Ziehbrunnen.java)

public class Ziehbrunnen {
	
	public static void main(String[] args){
		Ziehbrunnen ziehbrunnen=new Ziehbrunnen();
	}
	
	int wasserTrog=0;
	Thread pumpe;
	Thread verteiler;
	boolean aktuellerWasserstand=false;
	

	public Ziehbrunnen(){
		pumpe=new Schoepfer(this,"Pumpe");
		verteiler=new Schoepfer(this,"Verteiler");
		pumpe.start();
		verteiler.start();
	}

	public synchronized void setWasserTrog(int mengeWasser){
	while(aktuellerWasserstand==true){
		try {
			pumpe.wait();
		} catch (InterruptedException e) {}
	}
	wasserTrog+=mengeWasser;
	aktuellerWasserstand=true;
	notifyAll();
	}
	
	
	public synchronized int getWasserTrog(){
		while(aktuellerWasserstand==false){
			try {
				verteiler.wait();
			} catch (InterruptedException e) {}	
		}
		aktuellerWasserstand=false;
		notifyAll();
		return wasserTrog;
	}
	

}

(2.Schoepfer.java)

import java.awt.*;

public class Schoepfer extends Thread {

	Ziehbrunnen ziehbrunnen;
	String geraet;
	int mengeWasser;
	boolean arbeit=true;
	
	public Schoepfer(Ziehbrunnen ziehbrunnen,String geraet){
		this.ziehbrunnen=ziehbrunnen;
		this.geraet=geraet;
	}

	public void run(){
		while(arbeit==true){
		mengeWasser=(int)(Math.random()*20);
			
		    if(geraet=="Pumpe")
		    	ziehbrunnen.setWasserTrog(mengeWasser);
		    	System.out.println("Pumpe:"+mengeWasser);
		    	System.out.println("Wassertrog:"+ziehbrunnen.getWasserTrog());
			if(geraet=="Verteiler")	
				ziehbrunnen.setWasserTrog(mengeWasser*(-1));
	    	    System.out.println("Verteile:"+mengeWasser);
	    	    System.out.println("Wassertrog:"+ziehbrunnen.getWasserTrog());
		try{
			sleep(1000);
		}catch(InterruptedException e){}
	}
  }
}

Bin ich so etwa auf dem richtigen Weg laut Aufgabenstellung?
MfG
Miklo

 

[SlaterB]

> while(arbeit==true){
->
while(arbeit){


> if(geraet=="Pumpe")
Strings nie mit ==, nur mit .equals() vergleichen

> Irgendwas mit den Threads geht einfach noch schief
soso

> Bin ich so etwa auf dem richtigen Weg laut Aufgabenstellung?
eine Frage, die nicht unbedingt Antworten fördert..,
denke selber nach und beschreibe konkrete Probleme, falls vorhanden

 

[Guest]

Hallo, danke für die Tipps wirklich nett.
Ich hab nun noch einmal selbst den Kopf eingeschalten und noch einige Fehler gefunden. Es ist jedoch immer noch ein Problem mit den Threads. Kann es sein , dass das Problem in jenem Abschnitt liegt?

        if(geraet.equals("Pumpe")){
		    	ziehbrunnen.setWasserTrog(mengeWasser);
		    	System.out.println("Pumpe:"+mengeWasser);
		    	System.out.println("Wassertrog:"+ziehbrunnen.getWasserTrog(mengeWasser));}
	if(geraet.equals("Verteiler")){
				ziehbrunnen.setWasserTrog(mengeWasser*(-1));
	    	    System.out.println("Verteile:"+mengeWasser);
	    	    System.out.println("Wassertrog:"+ziehbrunnen.getWasserTrog(mengeWasser));
			}

Weil ja sowohl die Pumpe als auch der Verteiler auf das objekt ziehbrunnen zugreifen und diese Parallel laufen, kann es doch sein, dadurch die Methoden get und set in ziehbrunnen ja synchronized sind , dass die eine gerade durch den anderen Thread blockiert ist, oder? Wie kann ich nun dem ziehbrunnen jedoch mitteilen, welches gerät gerade an der reihe ist und welches am warten ist?

Oder besagt die folgende Exception etwas anderes?

Pumpe:4
Exception in thread "Thread-2" Wassertrog:4
Verteile:16
java.lang.IllegalMonitorStateException: current thread not owner
at java.lang.Object.wait(libgcj.so.70)
at java.lang.Object.wait(libgcj.so.70)
at Ziehbrunnen.getWasserTrog(Ziehbrunnen.java:41)
at Schoepfer.run(Schoepfer.java:26)
Exception in thread "Thread-1" java.lang.IllegalMonitorStateException: current thread not owner
at java.lang.Object.wait(libgcj.so.70)
at java.lang.Object.wait(libgcj.so.70)
at Ziehbrunnen.setWasserTrog(Ziehbrunnen.java:23)
at Schoepfer.run(Schoepfer.java:20)

Wäre echt froh, um kleinen beistand. Mit diesen Threads ist für Beginner einfach verwirrend....:-(
(Es kann doch wirklich nicht grosses mehr sein woran mein Progrämmlchen scheitert, oder? - Komm einfach nicht zum ende)

MfG
Miklo

Nochmals der aktuelle Code
Schoepfer.java

import java.awt.*;

public class Schoepfer extends Thread {

	Ziehbrunnen ziehbrunnen;
	String geraet;
	int mengeWasser;
	boolean arbeit=true;
	
	public Schoepfer(Ziehbrunnen ziehbrunnen,String geraet){
		this.ziehbrunnen=ziehbrunnen;
		this.geraet=geraet;
	}

	public void run(){
		while(arbeit){
			mengeWasser=(int)(Math.random()*20);
			
		    if(geraet.equals("Pumpe")){
		    	ziehbrunnen.setWasserTrog(mengeWasser);
		    	System.out.println("Pumpe:"+mengeWasser);
		    	System.out.println("Wassertrog:"+ziehbrunnen.getWasserTrog(mengeWasser));}
			if(geraet.equals("Verteiler")){
				ziehbrunnen.setWasserTrog(mengeWasser*(-1));
	    	    System.out.println("Verteile:"+mengeWasser);
	    	    System.out.println("Wassertrog:"+ziehbrunnen.getWasserTrog(mengeWasser));
			}
		try{
			sleep(1000);
		}catch(InterruptedException e){}
	}
  }
}

Ziehbrunnen.java

public class Ziehbrunnen {
	
	public static void main(String[] args){
		Ziehbrunnen ziehbrunnen=new Ziehbrunnen();
	}
	
	int wasserTrog=0;
	Thread pumpe;
	Thread verteiler;
	boolean aktuellerWasserstand=false;
	

	public Ziehbrunnen(){
		pumpe=new Schoepfer(this,"Pumpe");
		verteiler=new Schoepfer(this,"Verteiler");
		pumpe.start();
		verteiler.start();
	}

	public synchronized void setWasserTrog(int mengeWasser){
	while(aktuellerWasserstand==true){
		try {
			pumpe.wait();
		} catch (InterruptedException e) {}
	}
	wasserTrog+=mengeWasser;
	aktuellerWasserstand=true;
	notifyAll();
	}
	
	
	public synchronized int getWasserTrog(int mengeWasser){
		while(aktuellerWasserstand==false){
			try {
				verteiler.wait();
			} catch (InterruptedException e) {}	
		}
		if( wasserTrog<mengeWasser){
			try{
				verteiler.wait();
			}catch(InterruptedException e){}
		}
		
		aktuellerWasserstand=false;
		notifyAll();
		return wasserTrog;
	}
	

}

 

[SlaterB]

du darfst nicht einfach so an einem anderen Thread/ an einem beliebigen Object wait() aufrufen?!
das geht nur, wenn du auch gerade in einem synchronized-Block zu diesem Objekt bist,

wenn du jetzt 'häh, was ist eigentlich synchronized' denkst,
dann solltest du das alles mal nachlesen,
und evtl. dazu gezielt üben/ Fragen stellen

naja, an Aufgaben lernt man ja auch gut

http://www.galileocomputing.de/openbook/javainsel6/javainsel_09_006.htm

insbesondere
9.6 Synchronisation über Warten und Benachrichtigen

insbesondere
9.6.3 Warten mit wait() und Aufwecken mit notify()