Здравствуйте. У меня такая проблема - требуется завершать дочерние потоки, если прерывается поток, который их породил. Родительский поток живет пока работают дочернее, используя join()
. Дочерние потоки используют в run()
- while (!Thread.currentThread.isInterrupted)
, то есть фактически бесконечные. Задача - прерывать дочерние потоки при прерывании родительского, при этом не объявляя дочерние потоки как демоны.
3 ответа
Когда я сталкивался с подобной задачей я решал ее так:
В дочернем потоке было булевское поле running со стандартными get и set методами, значение которого периодически проверялось. Когда родительский поток заканчивал работу, он вызывал метод setRunning(false). При очередной проверке, дочерний поток, увидев, что running == false, выходил из бесконечного цикла и заканчивал работу.
Добавил пример кода дочернего потока.
public class A extends Thread{
private boolean running;
public A(){
running = true;
}
public synchronized void setRunning(boolean r){
running = r;
}
public void run(){
while(!Thread.currentThread.isInteruped())
if(!running)
break;
}
}
-
У меня так не проканает, тк родительский поток просто висит и дожидается окончания дочерних потоков. то есть в нем все так: childThread.start(); childThread.join() и нужно сделать так чтобы по прерывании потока допустим из консоли завершались и порожденные– Vladimir19 сен 2011 в 15:56
-
То есть ты запускаешь в родительском потоке дочерний, говоришь родительскому ждать, пока завершится дочерний, но если родительскому ждать надоело и он завершается, то тебе надо завершить и дочерние. Так?– Sasha12119 сен 2011 в 16:11
-
-
Но ведь родительский поток не сам по себе завершится. Его завершит что-то извне. Разве это что-то извне не может получить ссылку на дочерний поток у родительского потока, чтобы вызвать у дочернего setRunning(false)?– Sasha12119 сен 2011 в 16:16
-
в идеале его завершает ctrl+c в консоли, он просто инрерапится. я вот думаю сработает ли отлов InterruptedException в родителе и в catch - интерапить дочерние– Vladimir19 сен 2011 в 16:23
вам нужен вариант реализации шаблона Observer (вариант Б в чистом виде)
(вариант А немножко скован тем что обьект потока создается внутри метода, поэтому добавлен Runnable в качестве параметра. можно сделать и с помощью generic, тогда ваш класс MainThread будет более универсален)
class MainThread extends Thread
{
private final Set < Thread > children = null;
// variant A
public Thread createChild ( final Runnable runnable )
{
final Thread t = new Thread ( runnable );
// optional
// t.start ();
children.add ( t );
return t;
}
@Override
public void interrupt ()
{
removeAll ();
super.interrupt ();
}
// variant B
protected void add ( final Thread child )
{
if ( ( null != child ) && !children.contains ( child ) )
{
children.add ( child );
child.start ();
}
}
protected void remove ( final Thread child )
{
if ( children.contains ( child ) )
{
children.remove ( child );
child.interrupt ();
}
}
protected void removeAll ()
{
final Iterator < Thread > iterator = children.iterator ();
while ( iterator.hasNext () )
{
iterator.next ().interrupt ();
}
}
}
class ChildThread extends Thread
{
public ChildThread ( final MainThread parent )
{
parent.add ( this );
}
public void interrupt()
{
if (isRunning)
{
isRunning = false;
}
}
public void run()
{
if (!isRunning)
{
super.interrupt();
return;
}
// полезный код... если ChildThread и runImpl сделать абстрактными
// то получится еще и красиво :)
runImpl();
}
}
UP: согласно пожеланиям публики убрал грубый interrupt :D
-
Согласен, что такой вариант тоже возможен и иногда даже эффективнее, но отличие моего варианта в том, что поток не прерывается в непредсказуемый для дочернего потока момент, а корректно завершается так, как этого захочет программист. Мой способ просто выводит поток из бесконечного цикла, после которого он может до завершения успеть выдать какой-нибудь результат.– Sasha12120 сен 2011 в 3:40
-
Чего то я не пойму - что при грубом прерывании родительского потока(допустим Ctrl+C c консоли) у него будет вызван его interrupt() ? Разве так ? По-моему join() выбросит InterruptedException и в catch уже можно будет интерапить родителя и дочерние. Вроде так. Поправьте если нет– Vladimir20 сен 2011 в 8:48
-
2 @Sasha121 ничего вам не напоминает ?:) зачем углублятся в ненужные детали. пытаясь решить проблему которую уже решили.– jmu21 сен 2011 в 1:06
-
2 @jmu - вопрос тот же - каким образом у меня вызовется interrupt если я просто убиваю процесс в JVM ?– Vladimir21 сен 2011 в 9:53
-
убить процесс JVM это тоже что вытянуть шнур с розетки. естественно что в JVM ничего вызвано не будет. обрисуйте детальнее вашу задачу? непонятно зачем вам останавливать JVM таким грубым методом– jmu21 сен 2011 в 16:46
Попробуйте посмотреть в сторону CyclicBarrier
-
При чем тут CyclicBarrier ? У меня дочерние потоки бесконечные и не достигают никогда никаких логических барьеров. я просто хочу правильно прекращать работу программы(потоков)– Vladimir20 сен 2011 в 10:06