VPF::ThreadPoolExecutor не работает - Форум программистов

DenisT

Дата 2.10.2009, 12:57 (ссылка)

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

Загрузка ...

Новичок

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

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

Написал небольшую программу чтобы поэкспериментировать с пулом потоков.

Код



import java.util.concurrent.*;

public class Main 
{
    public static void main(String[] args) 
    {
        ExecutorService pool = Executors.newFixedThreadPool(3);
        Task t = new Task();
        pool.submit(t);                
        pool.shutdownNow();
    }        
}

Код


import java.util.concurrent.Callable;

public    class Task implements Callable<Integer>
{
    @Override
    public Integer call()
    {
        while(true){}
    }
}

Заметил, что при завершении работы программы и выхода потока из метода main поток в пуле продолжает работать!
Подскажите, в чем может быть ошибка?

LSD

Дата 2.10.2009, 13:05 (ссылка)

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

Загрузка ...

Leprechaun Software Developer

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

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

Цитата(DenisT @ 2.10.2009, 12:57

)

Подскажите, в чем может быть ошибка?

Дело в том, что кое-кто не читает книг по Java. JVM завершает свою работу когда не остается ни одного работающего потока не демона. А завершился ли main() или нет ей плевать. Более того можно у апплетов main() вообще нет.

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

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.

DenisT

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

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

Загрузка ...

Новичок

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

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

Скорее дело в том, что кое-кто никогда раньше не работал с пулом потоков и запустить мой код тоже не потрудился.

это не объясняет, почему не отрабатывает метод pool.shutdownNow(); не завершает потоки в пуле. Я даже исходники смотрел, реализация данного метода - цикл по всем потокам пула и вызов для каждого метода interrupt()

Есть еще идеи?

LSD

Дата 2.10.2009, 13:22 (ссылка)

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

Загрузка ...

Leprechaun Software Developer

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

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

Цитата(DenisT @ 2.10.2009, 13:15

)

Скорее дело в том, что кое-кто никогда раньше не работал с пулом потоков и запустить мой код тоже не потрудился.

Код действительно не запускал, а вот с потоками и пулами работал достаточно.

Цитата(DenisT @ 2.10.2009, 13:15

)

это не объясняет, почему не отрабатывает метод pool.shutdownNow(); не завершает потоки в пуле. Я даже исходники смотрел, реализация данного метода - цикл по всем потокам пула и вызов для каждого метода interrupt()

Осталось только прочитать что именно делает метод interrupt() и соотнести его с кодом Task, чтобы понять что самому таску на все эти интерапты глубоко пофиг. Ты где нибудь внутри цикла проверяешь статус? smile

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

LSD

Дата 2.10.2009, 15:03 (ссылка)

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

Загрузка ...

Leprechaun Software Developer

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

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

Код


public class Test
{
  public static void main(String[] args) throws Exception
  {
    final int availableProcessors = Runtime.getRuntime().availableProcessors();
    ExecutorService pool = Executors.newFixedThreadPool(availableProcessors);
    for(int i = 0; i < availableProcessors; i++)
    {
      pool.submit(new Task());
    }
    Thread.sleep(10000);
    pool.shutdownNow();
  }

  public static class Task implements Callable<Integer>
  {
    public Integer call()
    {
      Thread currentThread = Thread.currentThread();
      while(!currentThread.isInterrupted())
      {
      }
      return 0;
    }
  }
}

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

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