Массив Потоков

public class Synch {
 
    class NewThread implements Runnable{
        Thread t;
            NewThread(){
                t = new Thread();
                t.start();
            }
        public void run() {
            
            try{
                        int i = 0;
                        System.out.println("Я поток номер  " + i);
                        i++;
                
                
                Thread.sleep(1000);
                
            }   catch (InterruptedException e){
                System.out.println("поток  прерван");
            
        }
        
        
        
    
 
 
    }  
    }
 
 
public static void main(String args[]){
    int n=Integer.decode(args[0]);
    int y;
    NewThread[] Th = new NewThread[n];
    for(y=0; y<n;){
        Th[y].run();
        y++;
    }
}
}

Сообщение отредактировано: Nort0n - 04.11.07, 22:43

Интересует вот что - возможна ли инициализация массива потоков, и как её следует производить. потому что ясно, что

NewThread[] Th = new NewThread[n];

работает некорректно.

Некорректно, это в смысле сваливается с NPE? Логично, ибо ты этой конструкцией только сам массив инициализируешь. А элементы кто делать будет?

public static void main(String args[]){
    int n=Integer.decode(args[0]);
    int y;
    NewThread[] Th = new NewThread[n];
    for(y=0; y<n;){
        Th[y] = new NewThread();
        Th[y].run();
        y++;
    }
}

Это раз. Только вот содержимое класса NewThread это порнография в чистом виде. Переписывать его не буду, ибо не могу уловить суть того, что должно происходить. Но конструктор, имхо, надо отчистить в любом случае.

Сообщение отредактировано: DUKe - 04.11.07, 22:59

Смею предположить, что автор мечтал увидеть нечто вроде этого(исправлял тупо чтоб работало, изначальный авторский стиль сохранен):

public class Synch {
 
    static class NewThread implements Runnable{
        Thread t;
        int i;
            NewThread(int i){
                this.i = i;
                t = new Thread(this);
                t.start();
            }
        public void run() {
 
            try{
//                        int i = 0;
                        System.out.println("Я поток номер  " + i);
//                        i++;
 
 
                Thread.sleep(1000);
 
            }   catch (InterruptedException e){
                System.out.println("поток  прерван");
 
        }
 
 
 
 
 
 
    }
    }
 
 
public static void main(String args[]){
    int n=Integer.decode(args[0]);
    int y;
    NewThread[] Th = new NewThread[n];
    for (int i = 0 ; i < n ;i++) {
        Th[i] = new NewThread(i);
    }
//    for(y=0; y<n;){
//        Th[y].run();
//        y++;
//    }
}
}

Добавлено 05.11.07, 01:28
Да, Nort0n, расскажи нам скорей, че ты хотел изобразит то?

НУ я хочу чтобы у меня создавалось, цитирую:



Есть N>2 потоков , каждый из которых выводит свое имя M>2 раз.
Нужно так синхронизовать потоки, чтобы имена выводились поочередно- в каскадном порядке.
(имя1 имя 2 имя 3 имя 4 имя 5 ….
имя 1 имя 2 имя 3 имя 4 имя 5 ….


но синхронизацию я решил пока что отложить и разобраться с массивом.

public class Synch {
    
        static class NewThread implements Runnable{
        Thread t;
        int i;
            NewThread(){      
                t = new Thread(this);
                t.start();
            }
        synchronized public void run(){
            int i = 0;
            for (i=0; i<5; i++){
              System.out.print("Я поток номер:" + i+ "  ");
              try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
              e.printStackTrace();
            }
            }
            System.out.println();
    }
    }
    public static void main(String args[]) throws InterruptedException{
        int n=Integer.decode(args[0]);
        int y;
        NewThread[] Th = new NewThread[n];
        for(y=0; y<n;){
            Th[y] = new NewThread();
          
            Thread.sleep(1000);  
            Th[y].run();                            
            Thread.sleep(1000);
            y++;
        }
    }
}

[censored]


ЗЫ: Кстати, решение выложил из чистого эгоизма - решил вспомнить работу с потоками, а то, что-то давно этим не занимался, если у кого(обращаюсь в основном к модераторам и Дюку) время будет - гляньте, можно ли это оптимальнее сделать

Сообщение отредактировано: wind - 06.11.07, 00:07

Konigsberg, вроде, все прилично. Хотя я тоже давно уже многопоточностью не баловался.

Как вариант модификации, можно сделать очередь, в которую сложить все потоки, и нотифицировать, только следующего в очереди, а себя добавлять в конец. Я правда не уверен, что это будет производительнее

Цитата DUKe @ 06.11.07, 00:17

Как вариант модификации, можно сделать очередь, в которую сложить все потоки, и нотифицировать, только следующего в очереди, а себя добавлять в конец. Я правда не уверен, что это будет производительнее

и как нотифицировать определенный поток?

Konigsberg, вот такой вот порнографией:

...
while (blocked) {}
blocked = true;
...
 
 
setBlocked(boolean blocked) {
    blocked = false;
}

Добавлено 06.11.07, 00:24
Хотя, чего-то я не подумал, потоки ж все время активными будут. Не нафиг такое решение

Цитата DUKe @ 06.11.07, 00:23

Хотя, чего-то я не подумал, потоки ж все время активными будут. Не нафиг такое решение

Konigsberg, знал, что после таких вечерних развлечений думать вредно... Чего-то я с ужасом понял, что я уже три часа статью пишу. Представляю, что я там написал... Надо утром перечитать. Вообщем заканчивая оффтоп: нормальное ты решение предложил.

Ок, сенкс, спать ложись Хотелось бы, что бы ещё wind глянул

Короче, констатирую факт: то, что ты изобразил со второй попытки - не пойдёт


Почему? (Закрывая глаза на то, что код корявый, ужасный etc.). ПОтоки синхронизированы (?), всё работает (?)

Цитата Nort0n @ 06.11.07, 07:18

ПОтоки синхронизированы (?), всё работает (?)

нет, нет
Твой "код" вообще мало чего делает из того, что должен Там даже потоков не то количество создается, что нужно, а уж то, что каждый поток тупо 5 раз выводит "я поток номер: 1, я поток номер 2,..." - ты сам то понимаешь что это бред? Зачем каждому потоку 5 раз писать что он поток номер 1-5? Тебе нужно, чтобы запускались все потоки, потом первый входил в цикл и выполнял первую итерацию, а все остальные ждали свою очередь, потом это делал второй поток, третий... Потом первый принимался за вторую, затем второй, третий... Это всё реализуется методами wait() и notifyAll() на общем для всех потоков мониторе. Советую тебе почитать про эти методы - они очень полезные И ещё - всё должно работать без подгонок с помощью sleep();

Цитата Konigsberg @ 06.11.07, 00:31

Хотелось бы, что бы ещё wind глянул

Konigsberg, я бы инкапсулировал блокировку в классе, аналогичном вашему Monitor:

class PassThruLock {
    
    int counter = 0, maximum;
    
    public PassThruLock(int maximum) {
        this.maximum = maximum;
    }
    
    public synchronized void tryPass(int number) throws InterruptedException {
        while (number != counter) {
            wait();
        }
    }
    
    public synchronized void passed() {
        counter = (counter + 1) % maximum;
        notifyAll();
    }
    
}

А, ну это понятно, я в принципе не особо задумывался на счет "проектирования" этого кода... Меня просто всё смущает мой прием с notifyAll() и циклом while() - как то мне не очень нравится, но придумать лучше не смог

Цитата Konigsberg @ 06.11.07, 10:48

Меня просто всё смущает мой прием с notifyAll() и циклом while() - как то мне не очень нравится, но придумать лучше не смог

Да нет, для примера нормально. Но лучше не использовать голые wait()/notify(), а обернуть их в классы вроде моего, иначе есть шанс помучиться уже с их синхронизацией (всё равно нужен флаг). А ещё лучше - использовать имеющиеся в пакете java.util.concurrent

Сообщение отредактировано: wind - 06.11.07, 10:57

Цитата

"я поток номер: 1, я поток номер 2,..." - ты сам то понимаешь что это бред?

теперь понимаю, спасибо.

Цитата

И ещё - всё должно работать без подгонок с помощью sleep()

я не знал. Спасибо за помощь

Цитата wind @ 06.11.07, 10:54

А ещё лучше - использовать имеющиеся в пакете java.util.concurrent

Ну это если 5ку юзать, в 4-ке то их не было

Цитата Nort0n @ 06.11.07, 10:54

я не знал. Спасибо за помощь

Не за что, лучше прочти про wait и notify

Цитата Konigsberg @ 06.11.07, 11:04

Ну это если 5ку юзать, в 4-ке то их не было

У автора этих классов есть пакет и для java 1.4 - util.concurrent. Он хоть устроен немного иначе, но предоставляет тот же функционал.

wind, сенкс

Сообщения были разделены в тему "spam"