Threads richtig beenden

[Java_IRL]

Hallo, ich habe folgeneds Problem:

Ich habe insgesamt 5 Threads, die auf eine run()-Methode zugreifen, die über ein flag gesteuert werden (soll)

public void run(){
          while (bla == false){

                   //tue etwas 
          }
}



for(int i=0;i<5;i++){

Thread[i].start();

}

Ich habe eine Methode, die besagtes Flag ändern soll um somit ALLE Threads zu beenden. Es geschieht aber rein gar nichts, die Threads enden einfach nicht.

Hat jemand ne Idee, woran das liegt ?

Vielen Dank

 

[Gast2]

Moin,

Hallo, ich habe folgeneds Problem:

Ich habe insgesamt 5 Threads, die auf eine run()-Methode zugreifen, die über ein flag gesteuert werden (soll)
[..]

Ich habe eine Methode, die besagtes Flag ändern soll um somit ALLE Threads zu beenden. Es geschieht aber rein gar nichts, die Threads enden einfach nicht.

das ist etwas wenig Code um das zu testen ... aber ein Gedanke - kann das sein das bei der Instanzierung Deiner Threads "bla" pro Instanz erzeugt wird?

hand, mogel

 

[Java_IRL]

Tut mir Leid. War wirklich etwas dürftig.

Ich hab mich an das Beispiel der Dining Philosophers gehalten, wo es folgenden Code gibt:

class Philosopher extends Thread {
   int identity;
   Chopstick left; Chopstick right;

   Philosopher(Chopstick left,Chopstick right){
   this.left = left; this.right = right;
   }

   public void run() {
     while (true) {
     try {
          sleep(…); // thinking
          right.get(); left.get(); // hungry
          sleep(…) ; // eating
          right.put(); left.put();
     } catch (InterruptedException e) {}
   }
}

Instantiiert wird dann wie folgt:

for (int i =0; i<N; ++i){

     // create Philosophers
     phil[i]=new Philosopher(
          stick[(i-1+N)%N],stick[i]);
     phil[i].start();

}

Bei mir ist es quasi genau dasselbe. Nur steht bei mir in der while-Schleife kein true, sondern eine Variable, die verändert werden kann.

Ich möchte halt gerne mit ändern der Variable alle Threads, die auf diese run()-Methode zugreifen beenden.

Gruß

 

[Gast2]

Moin,

class Philosopher extends Thread {
   int identity;
   Chopstick left; Chopstick right;

   Philosopher(Chopstick left,Chopstick right){
   this.left = left; this.right = right;
   }

   // --- 8< ---
   private static boolean ende = false;
   public static void Quit() { ende = true; }
   // --- 8< ---

   public void run() {
     while (!ende) {    // <==
     try {
          sleep(…); // thinking
          right.get(); left.get(); // hungry
          sleep(…) ; // eating
          right.put(); left.put();
     } catch (InterruptedException e) {}
   }
}

Philosopher.Quit(); alle beenden

hand, mogel

 

[Java_IRL]

Hallo nochmal..

habe mitlerweile festgestellt, dass ich doch ein anderes Problem habe, da ich deine Abbruchbedingung bereits ohne Erfolg versucht habe.

Und zwar ist es folgendes :

Zunächst sollte ich mal noch erwähnen, dass mein Programm, also sagen wir ein Philosoph, etwas von rechts nimmt und es nach links weitergibt. Sollte von rechts nichts mehr kommen, wird der Thread pausiert, mit wait(), solange, bis wieder etwas kommt.


Da allerdings am Ende des Programms alle gestarteten Threads pausiert sind laufen sie ja auch nicht mehr durch die while()-Schleife, womit natürlich auch ein Umsetzen des flags nichts mehr bringt.

Gibt's ne Möglichkeit, alle Threads in einem waitset auf einmal zu beenden ?

 

[SlaterB]

keine Ahnung was das waitset ist,
aber du könntest sie ja im gleichen Moment in ein normales ordentliches Set setzen,
dann ist das Beenden leicht: dieses Set durchlaufen und alle Threads darin beenden

 

[Java_IRL]

Slater, du bist mein Held.

Ich hatte die Threads bereits in nem Array. Auf die Idee bin ich aber nicht gekommen.

Klappt jetzt wunderbar.

Vielen Dank !