Что делать процессами которые остались от тредов Java?

Question

[reus]

В общем у меня возникла проблема. Так сложилось что приложение должно запускаться каждую минуту и жить около 40 сек. Судя по логам (логи поступают из stdout в файл) приложение завершает работу нормально и без ошибок, НО! htop показывает множество процессов этого приложения. Как я понимаю это процессы тредов.
Причем заметил особенность, если я запускаю приложение просто:
java -jar /path/app.jar
то все нормально. Но если я добавляю задачу в крон:
* * * * * java -jar /path/app.jar
То возникает такая беда с потоками.

Код работает приблизительно следующим обазом:
1. main создает экземпляр класса ThreadList и запускает метод .start()
2. TreadList получает экземпляры классов и вызывает

for (Advert adv : getAdverts()) {
			adv.start();
		}
		for (Advert adv : getAdverts()) {
			try {
				adv.join();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}

3. Класс Advert расширяет Thread и выполняет основную логику. Если он выполняется слишком долго вызывается исключение и вызывает метод interrupt()

Подскажите из-за чего могут не завершаться процессы потоков?

Comments

[Толстый Лорри]

Каждый процесс содержит как минимум один тред, но не наоборот. Если вы не создавали процесс умышленно, то треды создаются в контексте одного и того же процесса (в котором они были запущены).

вызывается исключение и вызывает метод interrupt()

Это неправильно, поток должен сам себя останавливать.

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

[reus]

Толстый Лорри: Я просто вызываю этот метод прямо из потока (по аналогу с return в методах). Не могли бы Вы подсказать более удачные варианты?

[Толстый Лорри]

reus: сначала я вас неправильно понял (перепутал с Thread.stop(), который вызывать и правда не рекомендуется ).
Насчет interrupt(), он просто устанавливает статус потоку "Тебя просят завершиться", сам поток и должен его анализировать ( if ( isInterrupted() ) return; ), иначе он не завершится. Этот статус нужен для того, чтобы влиять на выполнение потока извне. Если поток сам решил, что ему пора, то можно просто завершать его run() и всё.

Видимо, так и выходит, что каждую минуту у вас запускается программа снова и снова (те самые процессы), а старый инстанс продолжает висеть на join'ах "вечных" потоков =)

[reus]

Толстый Лорри: А Вы не могли бы привести пример if ( isInterrupted() ) return;
то есть нужно сделать приблизительно так?

long startTime = System.currentTimeMillis();
long timeReserve = 20000 // milis
while ((startTime - System.currentTimeMillis())<timeReserve){
  if ( isInterrupted() ) return;
  if (..){}
  try {Thread.Sleep(1000)}
  catch (Exception e){}
}

Вы такую реализацию имели в виду?

Answer 1

[ruslanys]

А почему бы Вам не сделать запуск тредов внутри приложения? Важно понимать разницу между процессом и потоком:

В реальной жизни самое главное отличие между ними с точки зрения производительности заключается в том, что поток выполнения использует одну и ту же область памяти, а процессы получают собственные области. Поэтому отдельные процессы требуют гораздо больше памяти.

Мало того, запуск JVM каждые 40 секунд также имеет свои издержки.
Правильно было бы запускать приложение 1 раз, а уж оно каждые 40 секунд запускает ваши `Advert` потоки.

ИМХО

Comments

[reus]

На самом деле проблем с самими потоками нет. В коде был косяк, он уже исправлен и все нормально работает.
По поводу запуска JVM, а в чем проблема? Приложение небольшое (10 метров на жестком и около 200 оперативы). Судя по логам для старта нужно около секунды

May 30, 2017 3:02:01 PM start

May 30, 2017 11:43:01 PM start

May 30, 2017 11:44:01 PM start

May 31, 2017 2:04:01 AM start