Thread Experiment

[Lybrial]

Hallo,

ich wollte heute mal ein wenig mit den Methoden von Thread "rumprobieren".
Dazu wollte ich ein Parkhaus simulieren.

Ich möchte das das Parkhaus eine bestimmte größe hat.
Die Autos die Parken wollen, müssen prüfen ob ein Platz frei ist, wenn ja
parken sie, wenn nein, müssen sie warten bis was frei wird.

Allerdings parkt bei mir nur ein auto und fährt dann wieder. Ich weiß leider noch
nicht so richtig wie ich das realisieren kann, das alle Autos parken bis das
parkhaus voll ist und dann warten und erst wieder reinfahren können sobald
wieder plätze frei sind.

Der Code:

Parkhaus:

public class Parkhaus implements Runnable {
	
	private boolean[] aAmount = new boolean[10];
	private Auto auto;
	
	public Parkhaus (Auto aAuto) {
		this.auto = aAuto;
	}
	
	public void run() {
		
		for (int i = 0; i < aAmount.length; i++) {
			aAmount[i] = false;
		}
		
		try {
			System.out.println("Auto parkt!");
			
			auto.enter(aAmount);
			
			try {
	            Thread.sleep((long)(10*Math.random()));
	        } catch (InterruptedException e) {
	            e.printStackTrace();
	        }
			
		} finally {
			synchronized (auto) {
				auto.notify();
			}
		}
		
		try {
			System.out.println("Auto fährt!");
			
			auto.exit(aAmount);
			
			try {
				Thread.sleep((long)(10*Math.random()));
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		} finally {
			synchronized (auto) {
				auto.notify();
			}
		}
	}
}

Auto:

public class Auto extends Thread {
    
    public void run() {
        
    	System.out.println("Parkaus öffnet!");
    	
    	synchronized(this) {
    		
    		Parkhaus parkhaus = new Parkhaus(this);
    		parkhaus.run();
    		
    		try {
    			this.wait();
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		}
    	}
        
    	System.out.println("Parkhaus schließt!");
    }
    
	public void enter(boolean[] aAmount) {
		for (int i = 0; i < aAmount.length; i++) {
			if (aAmount[i] == false) {
				aAmount[i] = true;
				break;
			} else {
				continue;
			}
		}
	}
	
	public void exit(boolean[] aAmount) {
		for (int i = 0; i < aAmount.length; i++) {
			if (aAmount[i] == true) {
				aAmount[i] = false;
				break;
			} else {
				continue;
			}
		}
	}
}

main:

public class main {
	public static void main(String[] args){
	    
		Auto[] autos = new Auto[20];
		
		for (int i = 0; i < autos.length; i++) {
			autos[i] = new Auto();
			autos[i].run();
		}
	}
}

Ich danke für Hilfe

 

[faetzminator]

Ich sehe gleich den Fehler, dass du [c]run()[/c] statt [c]start()[/c] aufrufst. [c]start()[/c] erstellt einen neuen Thread und ruft in diesem [c]run()[/c] auf.

 

[Lybrial]

Oh ok, danke das hilft schonmal weiter, jetzt kann ich weiter analysieren
wie ichs richtig hinbiegen muss

 

[SlaterB]

Parkhaus sollte kein Thread sein und jedes Auto besser auch nicht sein eigenes Parkhaus aufmachen, das wäre doch langweilig
Parkhaus wird einmal in der main erstellt und an alle Threads übergeben,
von Auto aus nur
> parkhaus.enter(this);
oder ähnliches aufrufen, das boolean[] von Parkaus muss doch nicht an Auto übergeben werden,
Parkhaus sollte den meisten Code erhalten

 

[Lybrial]

Bekomme es nicht hin....habe viele Stunden hinter mir.....

public class Parkhaus extends Thread {
	
	private boolean[] aAmount = new boolean[10];
	private Auto[] autos;
	
	public Parkhaus (Auto[] aAutos) {
		autos = aAutos;
	}
	
	public void run() {
		
		for (int i = 0; i < aAmount.length; i++) {
			aAmount[i] = false;
		}
		
		System.out.println("Parkaus öffnet!");
		
		try {
			
			for(int i = 0; i < autos.length; i++) {
				autos[i].run();
			}
			
			try {
	            Thread.sleep((long)(10*Math.random()));
	        } catch (InterruptedException e) {
	            e.printStackTrace();
	        }
			
		} finally {
			synchronized (autos) {
				for(int i = 0; i < autos.length; i++) {
					autos[i].notify();
				}
			}
		}
		
		System.out.println("Parkhaus schließt");
		
	}
	
	public void enter() {
		
		for (int i = 0; i < aAmount.length; i++) {
			if (aAmount[i] == false) {
				aAmount[i] = true;
				
				System.out.println("Auto parkt!");
				
				break;
			} else {
				continue;
			}
		}
	}
	
	public void exit() {
		for (int i = 0; i < aAmount.length; i++) {
			if (aAmount[i] == true) {
				aAmount[i] = false;
				
				System.out.println("Auto fährt!");
				
				break;
			} else {
				continue;
			}
		}
	}
}

public class Auto implements Runnable {
	
	Parkhaus parkhaus;
	
	public Auto(Parkhaus aParkhaus) {
		parkhaus = aParkhaus;
	}
    
    public void run() {
    	
    	synchronized(this) {
    		
    		try {	
    			parkhaus.enter();
    		} finally {
    			synchronized(parkhaus) {
    				parkhaus.notify();
    			}
    		}
    		
    		try {
    			this.wait();
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		}
    		
    		try {
    			parkhaus.exit();
    		} finally {
    			synchronized(parkhaus) {
    				parkhaus.notify();
    			}
    		}
    	}
    }
}

public class main {
	public static void main(String[] args){
		
		Auto[] autos = new Auto[20];
		Parkhaus parkhaus = new Parkhaus(autos);
		
		for (int i = 0; i < autos.length; i++) {
			autos[i] = new Auto(parkhaus);
		}
		
		parkhaus.start();
	}
}

Der Algo hackt jetzt und terminiert nicht, Parkhaus öffnet, ein Auto Parkt dann ist
Feierabend, bräuchte nen Anstoß, weil ich mich total verkopft habe...

Danke im Vorraus

 

[pl4gu33]

also Threads sind schon ne Weile her,... aber wenn du Auto extends Thread machst und dann in Parkhaus

for(int i = 0; i < autos.length; i++) {
                autos[i].start();
            }

oder so aber ich würde extends Thread machen,...

    for(int i = 0; i < autos.length; i++) {
                new Thread(autos[i]).start();
            }

sodass ein eigener Thread pro Auto startet

dann parken schonmal 10 Autos
und dann gibts eine "IllegalMonitorStateException"

achja und Parkhaus is immer noch nen eigener Thread,... das brauchst du auch nicht, da Parkhaus dann im MainThread laufen kann

ich hoffe das hilft und hoffe meine Threads Kenntnisse sind nicht eingestaubt

ps. soweit ich das mal gelernt habe, Wait immer in einer While- Schleife, die die Bedingung prüft (in dem Fall,ob nun ein Platz im Parkhaus frei ist), da Notify auch von der JAVA Machine ab und zu aufgerufen werden kann !

und am Besten NotifyAll() außer es gibt nur eine Bedingung und die kann nur von einem Thread erfüllt werden,sodass eh nur ein Thread darauf wartet,...

€dit: sehe gerade du gibst doch wieder ein Platz frei, ich hatte nicht alles kopiert.... aber wie gesagt, bau den Thread um und dann parken schonmal mehr Autos ein

 

[SlaterB]

Parkhaus waited nie, wozu das notify von Auto an Parkhaus?

man kann nicht über ein Array synchronisieren und dann notify auf jedem Element aufrufen

------

wie ist dein Ablauf überhaupt generell geplant? alle Autos fahren rein und genau dann weg wenn das Parkhaus schließt?

-----

> da Notify auch von der JAVA Machine ab und zu aufgerufen werden kann !
öh, ich hoffe doch wohl nicht..,
die Schleife kann durchaus sinnvoll sein, aber eher nur aus fachlichen Gründen, wenn mehrere warten, alle informiert werden, einer reinkommt und die anderen weiter warten müssen

 

[pl4gu33]

> da Notify auch von der JAVA Machine ab und zu aufgerufen werden kann !
öh, ich hoffe doch wohl nicht..,
die Schleife kann durchaus sinnvoll sein, aber eher nur aus fachlichen Gründen, wenn mehrere warten, alle informiert werden, einer reinkommt und die anderen weiter warten müssen

ich hab nochmal nachgeschaut
ich hab dir mal den Absatz kopiert, der damals in unserem Skript stand,... würde mich jetzt mal interessieren, ob das nicht stimmt

"In der Praxis aber darf eine JVM aus Gründen der effizienten Implementierung sogar dann einen Thread aus seinem wait() aufwecken, wenn tatsächlich gar kein notify auf diesem Objekt erfolgt ist ("spurious wakeup"). Deshalb sollte man wait() prinzipiell immer in einem while benutzen, und niemals in einem if."

zumindest war das mit eine der Begründungen für While,... den anderen hast ja auch genannt

 

[Lybrial]

Nein, Autos fahren rein, prüfen ob ein Parkplatz frei ist, wenn nicht
warten sie bis einer frei wird. Wenn einer frei ist, parken sie für
eine zufällige Zeit und fahren dann wieder.