VPF::И снова потоки - Форум программистов

skhilkov

Дата 26.9.2006, 06:30 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 371
Регистрация: 11.4.2006
Где: TOMSK

Репутация: 2
Всего: 7

Люди, прошу не кидать в меня камни - я прочитал и FAQ по потокам, и в книге читал - но методы(которые как я понимаю должны работать так), работают не так как я думаю.... Объясните плз на пальцах.....
НИже код в котором се просто - в main создается поток одного класса, который содержит в себе несколько потоков другого класса. Так вот, моя конечная цель - это чтобы главный поток поочереди запустил каждый из имеющихся у него в ArrayList потоков, при этом в промежутках выполняя свой код. Я пробовал и notify с wait - не получается, подскажите как правильно...

Код


import java.util.ArrayList;


public class TestThreadsSynchronization
{

    /**
     * @param args
     */
    
    public static void main(String[] args)
    {
        TestThreadsSynchronization head = new TestThreadsSynchronization();
        Thread1 mainThread = head.new Thread1();
        for(int i = 0; i < 5; i++)
        {
            mainThread.addThread(head.new Thread2(mainThread));
        }        
        mainThread.start();
    }
    
    public class Thread1 extends Thread
    {
        ArrayList list = new ArrayList();
        
        public Thread1()
        { 
            
        }
        
        public void run()
        {
            while (!list.isEmpty())
            {
                Thread2 tmp = (Thread2)list.get(0);
                tmp.start();
                try
                {
                    wait();
                }
                catch (InterruptedException e)
                {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                System.out.println("Thread1 ---------------------------------");
            }
        }
        
        public void addThread(Thread2 t)
        {
            list.add(t);
        }
    }

    class Thread2 extends Thread
    {
        Thread1 head = null; 
        public Thread2(Thread1 h)
        {
            head = h;
        }
        public void run()
        {
            for(int i = 0; i<1; i++)
            System.out.println("Thread2 +++++++++++++++++++++++++++++++++++");
//            if (!head.isAlive())
//            {
                try
                {
                    head.join();
                }
                catch (InterruptedException e)
                {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
//            }
//            notifyAll();
        }
    }
}

--------------------

Кто понял жизнь, тот не спешит.

LSD

Дата 26.9.2006, 09:59 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Цитата(Sun @ 26.9.2006, 10:57

)

Хм.. А что это за синтаксис такой?

Это создание внутреннего не статического класса, в статическом методе, тут все нормально.

--------------------

Disclaimer: this post contains explicit depictions of personal opinion. So, if it sounds sarcastic, don't take it seriously. If it sounds dangerous, do not try this at home or at all. And if it offends you, just don't read it.

skhilkov

Дата 26.9.2006, 10:13 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 371
Регистрация: 11.4.2006
Где: TOMSK

Репутация: 2
Всего: 7

Цитата(LSD @ 26.9.2006, 09:59)

Цитата(Sun @ 26.9.2006, 10:57

)

Хм.. А что это за синтаксис такой?

Это создание внутреннего не статического класса, в статическом методе, тут все нормально.

да, все окей, только вот потоки не хотят работать... smile

--------------------

Кто понял жизнь, тот не спешит.

Sun

Дата 26.9.2006, 10:26 (ссылка)

(нет голосов)

Загрузка ...

Account removed

Профиль
Группа: Экс. модератор
Сообщений: 1611
Регистрация: 14.8.2002

Репутация: 8
Всего: 48

Код


public void run()
        {
            while (!list.isEmpty())
            {
                Thread2 tmp = (Thread2)list.get(0);
                tmp.start();
                try
                {
                    wait();
                }
                catch (InterruptedException e)
                {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                System.out.println("Thread1 ---------------------------------");
            }
        }

Чего то я не понял чего ты тут добиваешься. В замкнутом цикле порождать потоки Thread2 и помещать их в первый элемент lista? Могу только посоветовать чтобы убрать Exception вызвать перед wait() synchronized(this)

Код


                Thread2 tmp = (Thread2)list.get(0);
                tmp.start();
                synchronized(this) {
                    try
                    {
                        wait();
                    }
                    catch (InterruptedException e)
                    {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }

Но все равно идея мне не понятна. Можно как-то проще переделать?

--------------------

Account removed

LSD

Дата 26.9.2006, 10:31 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Я тоже не совсем понял алгоритм, кто кого запускает, ждет и т.д.?
Ну и плюс ты вызываешь wait() и notifyAll() на разных объектах, это не даст никакого эффекта.

--------------------

skhilkov

Дата 26.9.2006, 10:47 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 371
Регистрация: 11.4.2006
Где: TOMSK

Репутация: 2
Всего: 7

Короче, я знаю что у меня неправильно, я спрашиваю КАК это сделать? Идея такая: есть некий поток(назовем thread1), у него есть массив (или список) других потоков(thread2). Затем thread1 берет и поочередно запускает все потоки thread2, которые есть в массиве, а сам во время действия этих потоков спит.После каждого запущеного потока thread2, поток thread1 просыпается, пишет в консоль сообщение, запускает следующий поток и снова спит! Ну вот вроде и все....

Добавлено @ 10:49

Цитата(Sun @ 26.9.2006, 10:26)

Код


public void run()
        {
            while (!list.isEmpty())
            {
                Thread2 tmp = (Thread2)list.get(0);
                tmp.start();
                try
                {
                    wait();
                }
                catch (InterruptedException e)
                {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                System.out.println("Thread1 ---------------------------------");
            }
        }

Код


                Thread2 tmp = (Thread2)list.get(0);
                tmp.start();
                synchronized(this) {
                    try
                    {
                        wait();
                    }
                    catch (InterruptedException e)
                    {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }

Но все равно идея мне не понятна. Можно как-то проще переделать?

да, кстати, там есть косяк - я забыл написать list.remove(0)

--------------------

Кто понял жизнь, тот не спешит.

powerOn

Дата 26.9.2006, 11:07 (ссылка)

(нет голосов)

Загрузка ...

software saboteur

Профиль
Группа: Участник
Сообщений: 4367
Регистрация: 7.10.2005

Репутация: 47
Всего: 159

Посмотри на это:

Код


import java.util.ArrayList;
import java.util.Iterator;

public class Main implements Runnable {
    
    public Main() {
    }

    public static void main(String[] args) {
        // TODO code application logic here
        Thread t = new Thread(new Main());
        t.start();
    }
    
    public void run() {
        ArrayList<Thread> al = new ArrayList<Thread>();
        for(int i = 0; i < 10; i++) {
            MyThread mt = new MyThread();
            mt.setThreadName("Thread" + i);
            al.add(new Thread(mt));
        }
        
        for (Iterator<Thread> it = al.iterator(); it.hasNext();) {
            Thread elem = it.next();
            elem.start();
            try {
                System.out.println("waiting....");
                elem.join();
            } catch (InterruptedException ex) {
                ex.printStackTrace();
            }
        }
    }
    
}

class MyThread implements Runnable {
    
    private String threadName = ""   ;
    
    public void run() {
        try {
            Thread.sleep(200);
        } catch (InterruptedException ex) {
            ex.printStackTrace();
        }
        System.out.println("Thread Running: " + threadName);
        
    }
    
    public String getThreadName() {
        return threadName;
    }
    
    public void setThreadName(String threadName) {
        this.threadName = threadName;
    }
}

--------------------

нет времени думать - нужно писать КОД!

LSD

Дата 26.9.2006, 11:13 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Код

public class TestThreadsSynchronization
{
  public static void main(String[] args)
  {
    Thread1 mainThread = new Thread1();
    for(int i = 0; i < 5; i++)
      mainThread.addThread(new Thread2());
    mainThread.start();
  }

  public static class Thread1 extends Thread
  {
    private ArrayList<Thread2> list = new ArrayList<Thread2>();

    public void run()
    {
      while(!list.isEmpty())
      {
        Thread2 tmp = list.remove(0);
        tmp.start();
        try
        {
          tmp.join();
        }
        catch(InterruptedException e)
        {
          e.printStackTrace();
        }
        System.out.println("Thread1 ---------------------------------");
      }
    }

    public void addThread(Thread2 t)
    {
      list.add(t);
    }
  }

  public static class Thread2 extends Thread
  {
    public void run()
    {
      for(int i = 0; i < 4; i++)
      {
        System.out.println("Thread2 +++++++++++++++++++++++++++++++++++");
        try
        {
          Thread.sleep(500);
        }
        catch(InterruptedException e)
        {
          e.printStackTrace();
        }
      }
    }
  }
}

--------------------

skhilkov

Дата 26.9.2006, 11:25 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 371
Регистрация: 11.4.2006
Где: TOMSK

Репутация: 2
Всего: 7

Спасибо! Только я все-таки не понял - потоки могут оповещать друг друга или нет? Ну ладно, почитаю еще умных книжек - может допрет..... кстати, нет ли рекомендации насчет того, что почитать по этой теме?

--------------------

Кто понял жизнь, тот не спешит.

LSD

Дата 26.9.2006, 11:40 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Цитата(skhilkov @ 26.9.2006, 12:25

)

Могут.

Код

public class TestThreadsSynchronization
{
  public static void main(String[] args)
  {
    Object lock = new Object();
    Thread1 mainThread = new Thread1(lock);
    for(int i = 0; i < 5; i++)
      mainThread.addThread(new Thread2(lock, "Thread" + i));
    mainThread.start();
  }

  public static class Thread1 extends Thread
  {
    private ArrayList<Thread2> list = new ArrayList<Thread2>();
    private final Object lock;

    public Thread1(Object lock)
    {
      this.lock = lock;
    }

    public void run()
    {
      while(!list.isEmpty())
      {
        Thread2 tmp = list.remove(0);
        System.out.println("Starting " + tmp.threadName);
        tmp.start();
        try
        {
          synchronized(lock)
          {
            lock.wait();
          }
        }
        catch(InterruptedException e)
        {
          e.printStackTrace();
        }
      }
    }

    public void addThread(Thread2 t)
    {
      list.add(t);
    }
  }

  public static class Thread2 extends Thread
  {
    private final Object lock;
    public final String threadName;

    public Thread2(Object lock, String threadName)
    {
      this.lock = lock;
      this.threadName = threadName;
    }

    public void run()
    {
      doWork();
      synchronized(lock)
      {
        lock.notifyAll();
      }
      doWork();
    }

    private void doWork()
    {
      for(int i = 0; i < 2; i++)
      {
        System.out.println(threadName + " +++++++++++++++++++++++++++++++++++");
        try
        {
          Thread.sleep(500);
        }
        catch(InterruptedException e)
        {
          e.printStackTrace();
        }
      }
    }
  }
}

--------------------

batigoal

Дата 26.9.2006, 15:13 (ссылка)

(нет голосов)

Загрузка ...

Нелетучий Мыш

Профиль
Группа: Участник Клуба
Сообщений: 6423
Регистрация: 28.12.2004
Где: Санктъ-Петербургъ

Репутация: 24
Всего: 151

Цитата(skhilkov @ 26.9.2006, 12:25

)

кстати, нет ли рекомендации насчет того, что почитать по этой теме?

Вот: http://java.sun.com/docs/books/tutorial/es...ency/index.html

--------------------

"Чтобы правильно задать вопрос, нужно знать большую часть ответа" (Р. Шекли)
ЖоржЖЖ

skhilkov

Дата 26.9.2006, 16:40 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 371
Регистрация: 11.4.2006
Где: TOMSK

Репутация: 2
Всего: 7

Огромное всем спсибо!

--------------------

Кто понял жизнь, тот не спешит.

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Общие вопросы \| Следующая тема »