Threads Programm terminiert statt zu warten

[Shadoka]

Hallo und guten Morgen,

mein Problem ist, dass ich einen Thread eine bestimmte Zeit warten lassen möchte, nur terminiert das Programm an der Stelle, wo ich wait(long wait) aufrufe. Und das ohne Fehlermeldung.
Hier der Code:

	@Override
	public void run() {
		long wait;
		while (true) {
			wait = this.getWaitingTime();
			this.waitWithTime(wait);
			this.changeState();
		}
	}

	private synchronized void waitWithTime(long wait) {
		try {
			this.wait(wait);
		} catch (InterruptedException e) {
		}
	}

Die Methode getWaitingTime() liefert eine zufällige Zahl 0 < x <= 5000

Sieht vielleicht jemand einen Fehler?

Grüße,

Shadoka

 

[Kevin94]

Nutze Thread.sleep anstatt wait. Das tut was du willst.

 

[Shadoka]

Gerade ausprobiert, aber exakt dasselbe Problem. Terminiert jetzt an der Stelle, wo ich Thread.sleep() aufrufe.

 

[Jango]

Gerade ausprobiert, aber exakt dasselbe Problem. Terminiert jetzt an der Stelle, wo ich Thread.sleep() aufrufe.

Dann zeig mal den Code, wie du sleep einsetzt.

 

[Shadoka]

public class Philosopher implements Runnable {

	private State state;

	private Philosopher() {
		System.out.println("Wurde als denkend initialisiert");
		this.state = ThinkingState.create(this);
	}

	public static Philosopher create() {
		return new Philosopher();
	}

	@Override
	public void run() {
		long wait;
		while (true) {
			wait = this.getWaitingTime();
			this.waitWithTime(wait);
			this.changeState();
		}
	}

	private synchronized void waitWithTime(long wait) {
		try {
			System.out.println("davor");
			System.out.println(wait);
			Thread.sleep(wait);
			System.out.println("danach");
		} catch (InterruptedException e) {
			System.out.println("bin ich hier?");
		}
	}

	public void start() {
		Thread thread = new Thread(this);
		thread.start();
	}

	private long getWaitingTime() {
		Random rnd = new Random();
		long wait = rnd.nextLong() % 5000 + 1;
		if (wait <= 0) {
			wait = wait * -1 + 1;
		}
		return wait;
	}

	private void changeState() {
		this.setState(this.getState().accept(new StateVisitor() {

			@Override
			public State visit(EatingState state) {
				System.out.println("Wechsle in: denkend");
				return ThinkingState.create(Philosopher.this);
			}

			@Override
			public State visit(ThinkingState state) {
				System.out.println("Wechsle in: essend");
				return EatingState.create(Philosopher.this);
			}

		}));
	}

	public State getState() {
		return state;
	}

	public void setState(State state) {
		this.state = state;
	}
}

Das ist die komplette Klasse. Damit soll einfach erreicht werden, dass ein Philosoph nach zufälliger Zeit seinen Zustand wechselt.

€: Die System.out.printlns habe ich nur gesetzt um zu sehen, wo der Hase im Pfeffer liegt.

 

[Jango]

Ich bin mit Java auch nicht mehr soo fit, aber du kannst auch

 Thread.sleep(2000);

schreiben.

Arr... Ich muss mich mal wieder mit Java beschäftigen.

 

[Shadoka]

Das mache ich auch in Zeile 28
Ist von System.out.printlns umzingelt, sieht man vielleicht etwas schlecht.

 

[Kevin94]

Es wartet schon, der Problem ist wohl, dass in beiden Fällen die zeit in Millisekunden angegeben wird und du 100 ms eben schlecht wahrnehmen kannst. Ich nehme mal an, dass es einem erst bei mehr als 2s wirklich auffällt, dass pausiert wird. Probier doch mal folgenden Code für wait aus:

try {
System.out.println("davor");
System.out.println("Soll:"+wait);
long before=System.nanoTime();
Thread.sleep(wait);
long slept=System.nanoTime()-before;
System.out.println("danach");
System.out.println("Ist:"+slept*1e-6);// Umrechnen von ns in ms
} catch (InterruptedException e) {
System.out.println("bin ich hier?");
}

Theoretisch müsste wait in etwa slept entsprechen (plus minus etwa 10 ms), wenn das nicht der Fall ist, dann hast du ein ernsthaftes Problem mit deiner Java-Installation.

 

[Shadoka]

Ich hab das mal in deine Version umgeändert, dies kommt in der Konsole:

Wurde als denkend initialisiert
davor
Soll:952

Auch wenn ich eine Wartezeit von 4000ms habe ändert sich nichts daran. Es ist wirklich so, als ob das Programm an der Stelle wo ich Thread.sleep() aufrufe, terminiert.

 

[Jango]

Dann versuch es mit

TimeUnit.SECONDS.sleep(...);

 

[Kevin94]

Ist es so als ob es terminiert oder terminiert es wirklich. Also beendet es wirlich oder läuft es ewig weiter ohne eine weitere Ausgabe?

Am sleep kann es nicht liegen, das funktioniert so wie es ist, also muss das Problem irgendwo anders stecken, vielleicht im synchronized (das brauchst du bei sleep nicht). Ich hab keinen blassen Dunst, nach meinem Kenntnisstand gibt es keine Möglichkeit, dass nicht entweder eine Exception oder die Ist ausgabe in der Console kommt. Das einzige was mir einfallen würde ist ein Deadlock, ich kann mir aber nicht vorstellen, wie der während des sleeps zustande kommen soll. Wenn es einer wäre dürfte er nicht auftreten, wenn man das synchronized bei der Methode entfernt.

 

[Shadoka]

@Jango: Auch damit funktioniert es nicht, aber in der Funktion wird ja auch wieder dieselbe Thread.sleep() aufgerufen.

@Kevin94: Es terminiert wirklich, deswegen kann es auch nicht in einem Deadlock hängen...es ändert sich auch nichts, wenn ich das synchronized entferne.

Ich habe mir auch Beispiele aus dem Internet angesehen, aber ich kann da wirklich nicht erkennen, woran es bei mir liegen könnte...

 

[Kevin94]

Ich nehme mal an, dass es keine weiteren Ausgaben gibt (Exceptions), du nirgendwo System.exit aufrufst und auch nirgendwo Code hast, der Exceptions verschluckt. Wenn all dies zutrifft, bin ich ratlos. Was passiert wenn du das ganze drumherum weglässt und nur in ner Testklasse die wait methode ausführst?

 

[trääät]

also terminierung durch Thread.sleep() klingt schon ziemlich komisch ... zugegeben ... aber wie die ausgabe zeigt steigt das programm ja nun mal an genau der zeile wirklich aus ...
allerdings würde ich hier eher noch anderen code vermuten der drum herum abläuft aber nicht gepostet wurde ...
ansonsten hat deine java-install , dein os oder möglicherweise sogar deine hardware einen ziemlich heftigen schaden ...

versuche das problem mal auf ein compile-bares minimal-beispiel zu reduzieren ... denn so kann man es leider nicht selbst testen ...

 

[Shadoka]

Dies hier macht er ohne Probleme:

public class TestThreads {

	public void waitSomeTime(long time) {
		try {
			Thread.sleep(time);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

	public static void main(String[] args) {
		TestThreads test = new TestThreads();
		test.waitSomeTime(10000);
	}
}

Ich scheine da ein interessantes Problem zu haben...

 

[Kevin94]

Ich hatte nichts anderes erwartet. Das Problem muss irgenwo im restlichen Code stecken. Hast du bisher immer nur einen Thread gestartet?
Poste doch mal den noch nicht geposteten Code.

 

[trääät]

dann dürfte außerhalb irgendwas passieren was du nicht gepostet hast ... denn ich vermute der fehler steckt nicht im gepostetem sondern in irgendwas anderem was noch außen drumrum liegt ...

 

[Shadoka]

Ich habe ansonsten noch keine Logikklasse, ich hab ansonsten noch einen Visitor und ein State-Pattern, und in beiden Klassen wird nichts gemacht.

Ich habe es mal gepusht, auf GitHub könnt ihr das ganze Projekt sehen, aber es es ist außer dieser Klasse fast nichts.

https://github.com/Shadoka/Aufgaben/tree/master/DiningPhilosophers/src

Danke auch, dass ihr mir helft und so viele Tipps gebt

 

[florilu]

In einem meiner Programme habe ich es folgendermaßen gemacht, damit du nicht in Millisekunden rechnen musst ^^

static void sleep(int par1)
	{
		par1 = (par1 * 1000);
		try
		{
			Thread.sleep(par1);
		}catch(InterruptedException e){
			
		}
	}

Dann das Sleep iwo einfügen und dann z.B. "sleep(1)" eingeben damit er eine Sekunde "schläft".
Hoffe es kann dir weiterhelfen Auch wenn es sogesehen gelöst ist.

MfG:
Florilu

 

[Kevin94]

Ich bin mir zwar nicht sicher, ob es daran liegt, aber es ist das einzige was mir auffällt: Teste doch mal damit:

package test;

import philosopher.Philosopher;

public class TestPhilosophers {

public static void main(String[] args) {
Philosopher phil1=Philosoher.create();
phil1.start();
System.out.println("main beendet").
}
}

Wenn ich es mir recht überlege ist sogar ziemlich logich, das JUnit, nachdem alle Test abgeschlossen sind, die VM "hart" mit System.exit beendet.

 

[Shadoka]

Wow, danke!

Daran liegt es tatsächlich, was mich allerdings ein kleines bisschen wundert. In meinem kleinen Testprogramm oben lief es sowohl in der main()-Methode als auch unter Junit, deswegen hatte ich ausgeschlossen, dass es etwas damit zu tun haben kann.

Danke nochmal, jetzt kann ich endlich mit der eigentlichen Aufgabe anfangen