Логин:   Пароль:






Новости
Рассылки
Форум
Поиск


Java
- Апплеты
- Вопрос-ответ
- Классы
- Примеры
- Руководства
- Статьи
- IDE
- Словарь терминов
- Скачать

Мобильная Java
- Игры
- Примеры
- Статьи
- WAP, WML и пр.

JavaScript
- Вопрос-ответ
- Примеры
- Статьи

Веб-мастеринг
- HTML
- CSS
- SSI

Разминка для ума
Проекты
Книги
Ссылки
Программы
Юмор :)




Rambler's Top100
Rambler's Top100

Java: ПримерыРабота с вычислительными потоками с помощью класса Thread

Работа с вычислительными потоками с помощью класса Thread

Попробуем создать много вычислительных потоков, работающих вместе.

// класс потокового вычисления:
class MyTask extends Thread 
{ // предполагается, что MyTask вызывается только из класса Parent
  Parent main; 

   public MyTask(Parent main) 
   { 
      this.main = main; // вызывавший класс

      setDaemon(true); // ставим демона, чтоб поток был сам себе хозяин
      setPriority(Thread.NORM_PRIORITY); // устанавливаем приоритет
      start(); // и запускаем поток сразу же после инициализации
   }

   public void run() 
   { 
      // здесь нужно разместить код, который будет работать в отделтном потоке
      // для примера - for(int i = 0; i < 500; i++); // :o)
      // по завершению вычислений поток сигнализирует вызвавшему классу и 
      //самоуничтожается (причём самоуничтожается полностью, 
      //так как я поставил демона при инициализации)
      main.next();
      // в зависимости от вида функции next(), поток может передать результаты 
      //работы, свой ID или что-то ещё вызвавшему его классу
   } 
} 


// Ну вот и вызывающий класс:
class Parent 
{ 
   int started, tasks; // это глобальные переменные

   public Parent() 
   { 
      tasks = 20; // максимальное количество запущеных потоков
      started = 0; // количество уже запущеных потоков

     // создаём нужное количество потоков
      while(started < tasks) CreateTask(); 

// а теперь сидим и ждём, пока есть хоть один работающий поток
      while(started > 0); 
   } 

   // функция вызывающаяся по завершению работы потока
   // нужно заметить, что ставить синхронизацию и публичность обязательно
   // в функцию может передаваться результаты работы потока, 
   // ID задачи и т.д. 
   // в данном случае функция просто поддерживает одинаковое кол-во 
   // работающих потоков
   synchronized public void next() 
   { 
       // функция вызывается только по завершению потока, 
      //поэтому уменьшаем счётчик количества запущеных потоков
      started --; 
      // и если запущеных потоков меньше tasks, 
      //то запускаем ещё один
      if(started < tasks) CreateTask(); 
      // только для того, чтобы этот пример не работал вечно, уменьшаем потолок 
      //количества запущеных потоков
      tasks--; 
   } 

  // функция запуска нового потока
   // тоже обязательно должна быть синхронизирована, 
   // Protected я добавил от себя лично :o)
   synchronized protected void CreateTask()
   {  // увеличиваем значение запущеных потоков 
      started++; 
      // и просто создаём новый объект, а там уже прописано, 
      //чтоб он стартовал... 
      MyTask task = new MyTask(this); 
   } 
}


Warning: mysql_connect() [function.mysql-connect]: Can't connect to local MySQL server through socket '/tmp/mysql.sock' (2) in /pub/home/javaport/javaportal/books/show2b.php on line 11

Warning: mysql_db_query() [function.mysql-db-query]: Can't connect to local MySQL server through socket '/tmp/mysql.sock' (2) in /pub/home/javaport/javaportal/books/show2b.php on line 19

Warning: mysql_db_query() [function.mysql-db-query]: A link to the server could not be established in /pub/home/javaport/javaportal/books/show2b.php on line 19

Warning: mysql_fetch_array(): supplied argument is not a valid MySQL result resource in /pub/home/javaport/javaportal/books/show2b.php on line 30
Узнай о чем ты на самом деле сейчас думаешь тут.


[an error occurred while processing this directive]



Warning: mysql_connect() [function.mysql-connect]: Can't connect to local MySQL server through socket '/tmp/mysql.sock' (2) in /pub/home/javaport/javaportal/news/worldnews.php on line 91

Warning: mysql_db_query() [function.mysql-db-query]: Can't connect to local MySQL server through socket '/tmp/mysql.sock' (2) in /pub/home/javaport/javaportal/news/worldnews.php on line 93

Warning: mysql_db_query() [function.mysql-db-query]: A link to the server could not be established in /pub/home/javaport/javaportal/news/worldnews.php on line 93

Warning: mysql_fetch_array(): supplied argument is not a valid MySQL result resource in /pub/home/javaport/javaportal/news/worldnews.php on line 95