[Java]Tworzenie losowej liczby wątków i oczekiwanie na ich zakończenie

[JegoWysokosc 0]

Witam, tak dla sportu postanowiłem sobie po programować.

Wymyśliłem sobie, że napiszę program, który będzie tworzył losową liczbę wątków. Każdy wątek wykonuje 10 iteracji przez losowa ilość sekund. Stworzyłem klasę "Tworzenie wątków", która w zamyśle ma tworzyć losową liczbę wątków. Niby wszystko powinno działać ale wątki się nie tworzą. Gdzie popełniam błąd?

 

import java.util.logging.Level;
import java.util.logging.Logger;

class TworzenieWatkow implements Runnable{
   Thread t;
   public TworzenieWatkow() {
       t = new Thread(this);
       t.start();
   }

   public void run(){
       int ilosc_watkow = (int)Math.random()*10;
       for(int i = 0; i < ilosc_watkow;i++){
           new Watek(String.valueOf(i));
       }
   }

}

public class Watek implements Runnable{
   Thread t;
   public Watek(String name){
       t = new Thread(this,name);
       System.out.println("Utworzono watek: "+t.getName());
       t.start();        
   }
   public void run(){
       int sleeptime = (int)(Math.random() * 1000);
       for(int i = 0;i < 10;i++){
           try {
               Thread.sleep(sleeptime);
           } catch (InterruptedException ex) {
               Logger.getLogger(Watek.class.getName()).log(Level.SEVERE, null, ex);
           }
       }
       System.out.println("Koniec watku "+t.getName());
   }


   public static void main(String[] args) {
           TworzenieWatkow tw = new TworzenieWatkow();
       try {

           System.out.println("Oczekiwanie na zakonczenie watkow");
           tw.t.join();

       } catch (InterruptedException ex) {
           Logger.getLogger(Watek.class.getName()).log(Level.SEVERE, null, ex);
       }
       System.out.println("Koniec pracy wątków");
   }
}

[EF 0]

Nie startujesz watkow w petli?

[badman 0]

może spróbuj tak:

 

Watek w1 = new Watek();
(new Thread(w1)).start();

[JegoWysokosc 0]

Nie startujesz watkow w petli?

Wątek startuje w konstruktorze

 

Chyba, że widzisz coś co ja przeoczyłem

[revcorey 0]

to takei thread.start() to już od javy se5 nie jest zalecane jako metoda startowania wątków. Powinno używać się wykonawców.

[pleban_aq 0]

Witam, tak dla sportu postanowiłem sobie po programować.

Wymyśliłem sobie, że napiszę program, który będzie tworzył losową liczbę wątków. Każdy wątek wykonuje 10 iteracji przez losowa ilość sekund. Stworzyłem klasę "Tworzenie wątków", która w zamyśle ma tworzyć losową liczbę wątków. Niby wszystko powinno działać ale wątki się nie tworzą. Gdzie popełniam błąd?

 

import java.util.logging.Level;
import java.util.logging.Logger;

class TworzenieWatkow implements Runnable{
   Thread t;
   public TworzenieWatkow() {
       t = new Thread(this);
       t.start();
   }

   public void run(){
       int ilosc_watkow = (int)Math.random()*10;
       for(int i = 0; i < ilosc_watkow;i++){
           new Watek(String.valueOf(i));
       }
   }

}

public class Watek implements Runnable{
   Thread t;
   public Watek(String name){
       t = new Thread(this,name);
       System.out.println("Utworzono watek: "+t.getName());
       t.start();        
   }
   public void run(){
       int sleeptime = (int)(Math.random() * 1000);
       for(int i = 0;i < 10;i++){
           try {
               Thread.sleep(sleeptime);
           } catch (InterruptedException ex) {
               Logger.getLogger(Watek.class.getName()).log(Level.SEVERE, null, ex);
           }
       }
       System.out.println("Koniec watku "+t.getName());
   }


   public static void main(String[] args) {
           TworzenieWatkow tw = new TworzenieWatkow();
       try {

           System.out.println("Oczekiwanie na zakonczenie watkow");
           tw.t.join();

       } catch (InterruptedException ex) {
           Logger.getLogger(Watek.class.getName()).log(Level.SEVERE, null, ex);
       }
       System.out.println("Koniec pracy wątków");
   }
}

To nie ma prawa zadziałać. Ale z bardzo głupiego powodu:

kolejność operatorów: int ilosc_watkow = (int)Math.random()*10;

najpierw jest Math.random(), który zawsze daje wynik <1, potem (int), który ten wynik konwertuje do 0 co pomnożone przez 10 daje 0, ergo żaden wątek się nie utworzy

[JegoWysokosc 0]

To nie ma prawa zadziałać. Ale z bardzo głupiego powodu:

kolejność operatorów: int ilosc_watkow = (int)Math.random()*10;

najpierw jest Math.random(), który zawsze daje wynik <1, potem (int), który ten wynik konwertuje do 0 co pomnożone przez 10 daje 0, ergo żaden wątek się nie utworzy

Faktycznie, nie zauważyłem. Dziękuję za pomoc:-)

 

A tak kontynuując temat...

 

Poprzednia wersja tego programu wyglądała mniej więcej tak (piszę z pamięci):

Klasa Watek bez zmian

 

    public static void main(String[] args) {
       int ilosc_watkow = (int) Math.random() * 10;

       //Wiem, ze to mozna na listach zrobic ale nie o to tu chodzi...
       //tablica watkow
       Watek[] w = new Watek[ilosc_watkow];

       // Tworzenie watkow
       for(int i = 0; i < w.length;i++){
           w[i] = new Watek(String.valueOf(i));
       }
       // Oczekiwanie na zakonczenie wszystkich watkow
       for(int i = 0;i < w.length;i++){
           try {
               w[i].t.join();
           } catch (InterruptedException ex) {
               Logger.getLogger(Watek.class.getName()).log(Level.SEVERE, null, ex);
           }
       }
   }

To działało wyśmienicie ale nie podobało mi się to, że trzeba było za pomocą pętli czekać na zakończenie wątków. Stąd się wziął mój pomysł stworzenia wątku który by tworzył wątki (wiem, mało logicznie to brzmi)

 

Jak zrobić żeby wątek główny czekał na zakończenie innych wątków bez użycia pętli?

[revcorey 0]

zawieszanie i wybudzanie wątków.

http://download.oracle.com/javase/tutorial/essential/concurrency/index.html

[JegoWysokosc 0]

zawieszanie i wybudzanie wątków.

http://download.oracle.com/javase/tutorial/essential/concurrency/index.html

A możesz napisać jak algorytm by wyglądał w moim przypadku?

[revcorey 0]

klepnij w google notify i wait

[JegoWysokosc 0]

klepnij w google notify i wait

Akurat zasada działania notify i wait to nie problem, miałem na myśli podpowiedź w stylu "Zawieś wątek X, a potem sprawdź stan wątku Y..."

 

W każdym razie dziękuję za wszystkie podpowiedzi