Демонстрация применения групп потоков

[B]public class NewThread[/B] extends Thread {
 
    boolean suspendFlag;
 
    NewThread(String threadname, ThreadGroup tgOb) {
        super(tgOb, threadname);
        System.out.println("Новый поток: " + this);
        suspendFlag = false;
        start(); // Запуск потока
    }
//Точка входа потока,
    public void run() {
        try {
            for (int i = 5; i > 0; i--) {
                System.out.println(getName() + " : " + i);
                Thread.sleep(1000);
                synchronized (this) {
                    while (suspendFlag) {
                        wait();
                    }
                }
            }
        } catch (Exception e) {
            System.out.println("Исключение в " + getName());
        }
        System.out.println(getName() + " завершается.");
    }
 
    synchronized void mysuspend() {
        suspendFlag = true;
    }
 
    synchronized void myresume() {
        suspendFlag = false;
        notify();
    }
}
 
 
 
 
[B]public class ThreadGroupDemo[/B] {
 
    public static void main(String args[]) {
        ThreadGroup groupA = new ThreadGroup("Группа A");
        ThreadGroup groupB = new ThreadGroup("Группа В");
        NewThread ob1 = new NewThread("Один", groupA);
        NewThread ob2 = new NewThread("Два", groupA);
        NewThread ob3 = new NewThread("Три", groupB);
        NewThread ob4 = new NewThread("Четыре", groupB);
        System.out.println("Вывод из list():");
        groupA.list();
        groupB.list();
        System.out.println();
        System.out.println("Прерывается группа A");
        Thread tga[] = new Thread[groupA.activeCount()];
        groupA.enumerate(tga); // получить потоки группы
        for (int i = 0; i < tga.length; i++) {
            ((NewThread) tga[i]).mysuspend(); // приостановить каждый
// поток
        }
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            System.out.println("Главный поток прерван.");
        }
        System.out.println("Возобновление Group A");
        for (int i = 0; i < tga.length; i++) {
             ((NewThread) tga[i]).myresume();// возобновить все потоки в
// группе
        }
// Ожидать завершения потоков
        try {
            System.out.println("Ожидание остановки потоков.");
            ob1.join();
            ob2.join();
            ob3.join();
            ob4.join();
        } catch (Exception e) {
            System.out.println("Исключение в основном потоке");
        }
        System.out.println("Основной поток завершен.");
    }
}