Threads kontrollieren

[DerProgrammierer78]

Hallo liebe Forengemeinde,

Ich arbeite seit ein paar Wochen mit Java und stoße gerade auf ein Problem, dass ich auch mit meinen Büchern nicht gelöst bekomme.

Ich möchte in meiner main einen Prozess drei mal starten. Dann soll ein mal pro Sekunde überprüft werden ob einer der drei Prozesse fertig ist. Für jeden fertigen Prozess soll wieder ein neuer gestartet werden, so dass immer drei Prozesse parallel laufen und meine Daten verarbeiten.

Das alleine wäre ja nicht das Problem. Ich benenne diese einfach Prozess A, B und C und füge diese hartcodiert ein.

Nun kommt aber mein Problem ...

Ich möchte beim Programmstart zwei Variablen übergeben. Die eine soll die Anzahl der Prozesse steuern, dass man je nach Rechenleistung mehr oder weniger einstellen kann. Die andere soll die maximale Laufzeit in Sekunden für einen Prozess angeben. So dass ein Prozess, der mit seinen Berechnungen nach X Sekunden nicht fertig ist automatisch abgebrochen und ein neuer gestartet wird.

Und genau da scheitere ich derzeit ...

Wie soll ich da vorgehen oder gibt es da schon irgendwo einen Codeschnipsel an dem ich mich orientieren kann?

Gruß

DerProgrammierer78

 

[bygones]

schau mal nach:
ExecutorService (Java Platform SE 6))

 

[DerProgrammierer78]

Das liest sich interessant und könnte mein Problem evtl. lösen ... leider weiss ich nicht, wie ich das anwenden kann und werde auch aus dem Beispiel oben auf der Seite nicht schlau, da ich es da nicht finde ...

#edit

Ich meine da ich nicht finde, wie ich es da einbauen muss ...

 

[Paddelpirat]

Habe gerade auch mal etwas mit der Klasse ExecutorService rumgespielt, aber ich glaube das Verhalten was DerProgrammierer78 sucht kann man damit nicht 100%ig nachbilden.

Für den Fall der 3 parallelen Threads:

Die Methode invokeAll() versehen mit einem Timeout kommt erst zurück, wenn alle 3 aufgetragenen Aufgaben von den Threads abgearbeitet wurden, bzw. im worst case vom Timeout beendet worden sind. Erst danach kann man 3 neue Aufgaben an die Threads weiter geben.

Die Methode invokeAny() versehen mit einem Timeout kommt zurück, nachdem eine der drei Aufgaben abgearbeitet worden ist. Die anderen Aufgaben werden einfach abgebrochen...

Und die Methode submit() mit der man ein Future Objekt erhält, was man wiederum per get()-Methode mit einem Timeout versehen kann blockiert nach jedem Einzelaufruf einer Aufgabe, bis sie zurückkommt oder im worst case per Timeout beendet wird.

Von daher bleibt wohl nichts anderes übrig als für jeden Thread, der eine Aufgabe abarbeiten soll auch noch zusätzlich einen Timer-Thread zu erstellen, der überprüft wie lange die Ausführung bereits andauert. Oder habe ich etwas übersehen und es geht doch einfacher? (Interessiert mich auch weil ich mal sowas ähnliches programmiert hatte...)

 

[DerProgrammierer78]

Hallo Paddelpirat,

Danke für deine Antwort ...

Das würde ich so machen, wenn ich wüsste wie ich Werte aus einem Thread in einem anderen Thread abfragen kann und dann den abgefragten Thread beenden kann.

Weil dann würde ich beim starten eines Threads die Startzeit in diesem in eine Variable legen, die ich in einem anderen dann abfrage.

Gruß

DerProgrammierer78

 

[Paddelpirat]

Ich denke ein Thread für die Zeitkontrolle aller Prozesse würde auch reichen. Hier die Idee dazu:

Zuerst erstellst du dir einen Prozess der etwa so aussehen kann (die Abfrage mit dem !timedout musst du so platzieren, dass die Schleife in der sich der Prozess aufgehangen hat abbricht):

class MyProcess implements Runnable
{
	boolean timedout = false;
	
	public MyProcess() {
		
	}
	
	public void run() {
		while(!timedout) {
			doSomething();
		}
	}
	
	public void setTimedout() {
		this.timeout = true;
	}
	
	private void doSomething() {
		
	}
}

Dann könntest du eine Hashtable oder ähnliches anlegen in der du den Prozess und die Startzeit festhälst.

Ein weiterer Thread prüft dann jede Sekunde (oder halt so Zeitnah wie du es brauchst), ob einer der Prozesse in der Hashtable abgelaufen ist. Wenn ja wird, falls der Prozess überhaupt noch existiert, die Methode setTimedout() des Prozesses aufgerufen, so dass dieser beendet wird. Anschließend kannst du das Wertepaar bestehend aus Prozess und Start-Zeit aus der Tabelle schmeißen.

Naja das wäre jetzt mal ein erster Ansatz... weiß halt nicht, ob es noch schöner geht.

 

[DerProgrammierer78]

Hallo Paddelpirat,

Vielen Dank für deine Antwort, aber irgendwie bleibt der in meinem Code immer an dieser Stelle hängen:

URLConnection url_connection = url_internet.openConnection();
try
{
    BufferedReader br = new BufferedReader(new InputStreamReader(url_connection.getInputStream()));
    HTMLEditorKit editorKit = new HTMLEditorKit();
    HTMLDocument htmlDoc = new HTMLDocument();
    htmlDoc.putProperty("IgnoreCharsetDirective", Boolean.TRUE);
    ...
    ... do something with loaded data
    ...
}
catch (Exception e)
{
   ... write error message to database
}

Er kommt also gar nicht erst zum Ende der While-Schleife

Gruß

DerProgrammierer78

 

[DerProgrammierer78]

Also ich habe nun zumindest schonmal eine Teillösung ...

Diese habe ich in einem Buch gefunden ...

public void run()
{
    try
    {
        while (!Thread.currentThread().isInterrupted() && Was zu tun)
        {
            ... arbeiten ... arbeiten ... arbeiten ...
        }
    }
    catch(InterruptedException e)
    {
        ... arbeiten beenden und ggf. Status ins Logfile schreiben ...
    }
    finally
    {
       ... aufräumen ...
    }
}

Nun frage ich mich aber, wie man einen Interrupt von einem Thread an einen anderen schicken kann, damit der eine den anderen beendet ???


Gruß

DerProgrammierer78

 

[André Uhres]

Es gibt Thread#interrupt(), allerdings ich bin eher dafür, einen eigenen boolean "running" auf "false" zu setzen.

 

[DerProgrammierer78]

Hallo André Uhres,

Danke für deine Antwort

Das habe ich versucht ... Leider bleibt er hängen und kommt nicht zum Ende der while(isRunnung)-Schleife ...

Wenn du dafür eine Lösung hättest, dann würde ich mich über diese freuen

Gruß

DerProgrammierer78

 

[Paddelpirat]

Kannst du nochmal etwas mehr Code reinstellen und zeigen, wie du versucht hast die Schleife bzw. generell den Prozess zum Abbruch zu bringen? Bzw. versteh ich gerade nicht, wo genau es hängen bleibt ohne dass der Prozess abgebrochen wird...

 

[DerProgrammierer78]

Hallo Paddelpirat,

Ich habe im Endeffekt nur das was oben steht in eine While-Schleife gepackt und der BufferedReader hört bei größeren Datenmengen oder wenn die Leitung zu langsam ist einfach nicht auf zu laden. Und das will ich umgehen, weil das meine restlichen Prozesse nur unnötig ausbremst. Dann lade ich lieber erst was anderes und kehre dann nochmal zu dieser Quelle zurück ...

Gruß

DerProgrammierer78

 

[Paddelpirat]

Mein Verständnisproblem liegt nur darin, dass du in dem Code, den du oben gepostet hast ja eigentlich nur die Verbindung zu irgendeiner URL aufbaust und diese jetzt über den InputStreamReader an den BufferedReader übergibst.

Das eigentliche Einlesen müsste ja erst noch kommen z.B. mit so etwas wie:

String zeile = br.readLine();
while(zeile != null) {
    System.out.println(zeile);
    zeile = br.readLine();
}

So und diese Schleife kannst du nun mit einer weiteren Variablen, z.B. dem boolean timedout erweitern:

String zeile = br.readLine();
while(zeile != null && !timedout) {
    System.out.println(zeile);
    zeile = br.readLine();
}

Wobei du das timedout halt über einen anderen Timer-Thread irgendwann auf true setzt. Dann ist das Einlesen vorzeitig beendet...

 

[DerProgrammierer78]

Achso ... das meinst du ... Sorry....

editorKit.read(br, htmlDoc, 0);
HTMLDocument.Iterator iter = htmlDoc.getIterator(HTML.Tag.VAR);
while (iter.isValid())
{
    ... hole Daten aus den Variablen und speichere diese in der Datenbank ...
}

Aber er hört schon auf bei "editorKit.read(br, htmlDoc, 0);" ...

 

[Paddelpirat]

Okay jetzt wirds unschön *g*... ich bezweifle, dass die Methode read() auf ein interrupt reagiert, aber man könnte das ganze umgehen und in einer while schleife verpacken:

BufferedReader br .... //wie in deinem Programm

String zeile = br.readLine();
ByteArrayInputStream bais = new ByteArrayInputStream(zeile.toArray());

while(zeile != null && !timedout) {

    editorKit.read(bais, htmlDoc, htmlDoc.getLength);
    bais = new ByteArrayInputStream(br.readLine().toArray());
}

br.close();

D.h. du verpackst jede Zeile des HTML Dokumentes in einem ByteArrayInputStream und lliest diesen dann in dein EditorKit rein.

Habs nicht ausprobiert ob es so klappt, aber das müsstest du ja schnell mal bei dir so einfügen können.