Thread beendet nicht

[gutenacht-steph]

Hallo,

ich habe ein "großes" Problem.

Der Normalfall eines Threads ist doch:
er entsteht, arbeitet seinen Dienst ab, und stirbt danach. So wie es sich gehört.

Aber der liebe Herr Thread möchte bei mir nicht sterben.

Ich hoffe ich kann euch das Problem halbwegs gut erklärt schildern.

Ich habe eine Klasse Ping, welche von Thread erbt.
In der run() Methode von Ping befindet sich eine Endlosschleife, in der immer wieder ein Teil meiner SW "angepingt" wird.

Das Problem ist, dass der Arbeitsspeicherverbrauch meines Programms von anfänglichen 50MB unter Linux auf 400MB ansteigt (nach ca. 3min), unter Windows verdoppelt sich der Speicherverbrauch von 30MB auf 60MB. Es sei mal so dahingestellt dass Windows weniger verbraucht ;-). Die CPU-Auslastung beträgt dann 97%~100%.

Ich habe in meinem Programmcode einen activeCount() in einem System.out.pritntln, damit mir angezeigt wird, wieviele Threads existieren. Es werden immer mehr, bei jedem Schleifendurchlauf steigt die Anzahl um einen. Bei ca. 140 Threads kommen die 97% CPU-Auslastung zum Vorschein.

In der Schleife werden Klassen aufgerufen bzw. Methoden, die auch Threads enthalten (die Klassen bauen Verbindung zum Telnet auf, ich hab sie nicht selber programmiert, kenne sie also nur grob).

Jedenfalls ist es so, dass wenn ich bestimmte Objekte (von dem Telnet.. Code) auskommentiere, der activeCount() nicht ansteigt!

Bevor ich den Code jetzt poste. Es kann doch im Endeffekt nur daran liegen, dass die von mir auskommentierten Objekte, irgendwelche Threads erzeugen und diese Threads nicht sterben.
Oder?

Es geht eigentlich um das Prinzip, ich denke nämlich nicht, dass ihr besonders schlau werden könnt aus diesem Code.

class Ping extends Thread {

    java.beans.PropertyChangeSupport propChange = new java.beans.PropertyChangeSupport(this);
    Fehlerdiagnose fehlerdiagnose;
    static Client routerTest = new Client(5, 5);
  
    int internR = 0;

    public Ping(Fehlerdiagnose fd) {
        this.fehlerdiagnose = fd;
    }

    @Override
    public void run() {


        while (internR == 0) {
            boolean pingInternet;              //Ping
            System.out.println(activeCount());

            try {
                try {
                    Thread.sleep(2000);
                    internR = fehlerdiagnose.da.w.internI;
                } catch (InterruptedException ex) {
                    //  Logger.getLogger(runPing2.class.getName()).log(Level.SEVERE, null, ex);
                }
                pingInternet = Ping.ping("test");
                propChange.firePropertyChange("pingInternet", !pingInternet, pingInternet); 
            } catch (IOException ex) {
                Logger.getLogger(runPing2.class.getName()).log(Level.SEVERE, null, ex);
            }
    
            boolean pingAntenne;
 
            try {

                routerTest.connect(Properties.std_ip);   // wenn ich das hier auskommentiere
                

                try {
                  Fehlerdiagnose.Router = routerTest.isRouter();   // und das hier, gibt es keine Probleme
                } catch (TimeoutException ex) {
                    Fehlerdiagnose.Router = false;
                }

            } catch (SocketException en) {
                //  Logger.getLogger(Fehlerdiagnose.class.getName()).log(Level.SEVERE, null, en);
                Fehlerdiagnose.Router = false;
            } catch (IOException e) {
                //Logger.getLogger(Fehlerdiagnose.class.getName()).log(Level.SEVERE, null, e);
                Fehlerdiagnose.Router = false;
            }


            try {
                pingAntenne = Ping.ping(Properties.std_ip);
                propChange.firePropertyChange("pingAntenne", !pingAntenne, pingAntenne);  

            } catch (IOException ex) {
                Logger.getLogger(runPing2.class.getName()).log(Level.SEVERE, null, ex);
            }
            internR = fehlerdiagnose.da.w.internI;
            if (internR == 1) {
                routerTest = null;
            }
                
        }

    }

    public void addPropertyChangeListener(java.beans.PropertyChangeListener listener) {
        propChange.addPropertyChangeListener(listener);
    }

    public void removePropertyChangeListener(java.beans.PropertyChangeListener listener) {
        propChange.addPropertyChangeListener(listener);
    }
}

Wäre euch dankbar wenn Ihr mir helfen könntet.

 

[SlaterB]

ich einer Schleife wird Code ausgeführt und Code an sich beeinhaltet auch das Starten von Threads,
richtig,
wenn du die Aufrufe nicht näher diskutieren willst, dann kann da quasi alles mögliche passieren

der größte Teil deines Posting-Texts kümmert sich kaum mehr um die ursprüngliche Frage
> Aber der liebe Herr Thread möchte bei mir nicht sterben.

der Thread stirbt nicht solange die Schleife läuft, eigentlich logisch?
schaue genau wann wo warum die geprüfte Variable welchen Wert hat

 

[HoaX]

Ich gebe dir recht, dass es wohl am anderen Code liegt, wenn es durch auskommentieren nichtmehr auftritt.

Das wir aus dem Code nicht schlau werden werden hast du auch gut erkannt. Das ist echt ekelhaft zu lesen, das will ich nicht!

 

[gutenacht-steph]

Haha, kann ich verstehen.

Aber was köntnen Gründe z.B. für einen Thread sein, dass er nicht terminiert?

 

[w0ddes]

...
Aber was köntnen Gründe z.B. für einen Thread sein, dass er nicht terminiert?

Endlosschleifen?!

 

[SlaterB]

beinhaltete Funktion

 

[gutenacht-steph]

Oh man, jetzt funktioniert es.

Es lag wirklich an den anderen Klassen.
Das router.connect() hat in der anderen Klasse eine Verbindung zum Telnet aufgebaut, schön und gut.
Allerdings wurde dort weder der Input-, noch der Outputstream geschlossen.

Tja, habs nun geändert mit einer closed() Methode, und Schwubs die Wups, es funktioniert tadellos.

Vielen Dank für eure Hilfe, mir ist jetzt ein dicker Granitfels vom Herzen gefallen. Tu schon lange mit diesem Problem rum.