Thread-Objekte beenden/zerstören

[Florian Scheidler]

Hallo zusammen,

für meine Java-Anwendung habe ich einen automatischen zeitgesteuerten Emailversand programmiert. Jeder Emailversand bzw. Task läuft allerdings nur 1 mal pro Tag. Man kann je Task festlegen wann die Email(s), an welche Empfänger, mit welchem Betreff, Text und Absender und welchen Dateianhängen verschickt wird. Technisch ist das Ganze folgendermaßen umgesetzt:

- Gleich nach dem Einloggen in meine Anwendung wird je Task ein Objekt der Klasse Clock und ein Objekt der Klasse Clock2 gebildet. Diese Klassen sind abgeleitet von Thread und stellen beide eine Zeitschleife dar, welche ständig (alle 5 Sek.) prüft ob einer der Tasks fällig wird.

- Die Klasse Clock dient nur zur Warnung der Benutzer 10 min. vor dem Start eines Tasks. "Achtung: Bitte alle Listen überprüfen. In zehn Minuten wird verschickt!"

- Klasse Clock2 schliesslich verschickt die Emails der Tasks.

Ein Benutzer kann sich aus dem Tool ausloggen und gleich wieder unter einem anderen oder demselben Namen anmelden, ohne die Anwendung komplett zu beenden. Zum Problem wird das, weil die beim 1. Einloggen erstellten Objekte von Clock und Clock2 weiterhin bestehen bleiben und beim 2. Einloggen wieder neue Objekte von Clock und Clock2 gebildet werden. Nun ist alles doppelt gemoppelt und kann sogar bei mehrmaligem aus- und einloggen bis ins unendliche gesteigert werden.
Ich müsste also kurz vor dem Ausloggen, die bisher vorhandenen Objekte von Clock und Clock2 zerstören.

Mit

clock.destroy();
clock = null;
clock2.destroy();
clock2 = null;

geht es leider nicht, da schmeisst Java einen unknown Source-Error.

Bitte helft mir, wie kann ich vorhandene Thread-Objekte zerstören???

Gruß Florian Scheidler

 

[Oni]

hmm,

kannst du nicht einfach die gleichen objekte weiter benutzen und nur die wert auf default stellen?

wenn du die objekte auf null setzt sollt der gc sie eigentlich wegräumen, wie schneller er das macht kann man aber glaube ich nicht wirklich beeinflussen.

 

[Beni]

Anstelle von "destroy" kannst du "interrupt" benutzen. Das setzt ein Flag im Thread, welches du mit "interrupted" abrufen kannst (allerdings nur einmal, dann wird es wieder zurückgesetzt). Wenn der Thread gerade schläft, wird eine Exception geworfen.

public class Clock extends Thread{
  public void run(){
     while( !iiterrupted() ){
         try{
            Thread.sleep( 123456 );
         }
         catch( InterruptedException ex ){
             interrupt();
         }
     }
  }
}

Und aussen:

clock.interrupt();

 

[Florian Scheidler]

Das mit dem interrupt() habe ich auch gerade in meinem Buch gelesen und ausprobiert, aber leider funktioniert das nicht. Die beiden Klassen geben nach dem Logout weiterhin munter im 5 Sekunden-Takt etwas aus.
Sobald man sich ins Tool eingeloggt hat, öffnet sich das Hauptfenster, in welchem ich die private-Variablen:
clock und clock2 deklariert habe. In meiner Init()-Methode werden dann innerhalb einer Schleife für jeden aktiven Task zwei Objekte angelegt:

clock = new Clock(Stunde, Minute, Meldung, Hauptfenster.this);
clock2 = new Clock2(Stunde, Minute, taskID, aktuellerUser, Hauptfenster.this, taskName);

Wird dann auf den Logout-Knopf gedrückt, passiert folgendes:

//Öffnen des kleinen Login-Fensters

//Schliessen der Threads ??
clock.interrupt();
clock2.interrupt();

//Schliessen des Hauptfensters
dispose();
setVisible(false);

Am Ende sollte also nur das Login-Fenster übrig bleiben, leider lassen sich die Threads so aber nicht beenden.
Kann es vielleicht daran liegen, dass clock und clock2 bei mir Klassenvariablen sind und jeweils mehrmals zur Instanziierung der Objekte in der Schleife verwendet werden???

Bitte um Hilfe!

Gruß Florian Scheidler[/code]

 

[Florian Scheidler]

OK ich habs jetzt hinbekommen. Es lag wie ich schon vermutet hatte daran, dass ich für clock und clock2 nur jeweils eine globale private-Klassenvariable vom Typ Clock bzw. Clock2 verwendet habe, um unendlich viele (je nach Anzahl aktiver Tasks) Objekte in einer Schleife zu bilden.
Bei Beenden dieser Objekte mit interrupt() konnte ich nun logischerweise auch immer nur das letzte Objekt und somit den letzten Thread beenden, aber nicht alle.
Ich hab das nun gelöst, indem ich die Objekte der Thread-Klassen Clock und Clock2 in 2 Vectoren speichere und beim Logout alle diese Thread-Objekte in den Vectoren mit interrupt() beenden!

Gruß Florian Scheidler

 

[Sky]

Nur mal so am Rande: Für zeitgesteuerte Aufgaben steht Dir Timer und TimerTask zur Verfügung... das muss man nicht alles selber machen ;-)