Управление потоками

Core Java обеспечивает полный контроль над многопоточной программой. Вы можете разработать многопоточную программу, которую можно приостановить, возобновить или полностью остановить в зависимости от ваших требований. Существуют различные статические методы, которые вы можете использовать для объектов потока для управления их поведением. В следующей таблице перечислены эти методы:

№

Метод и описание

1

public void suspend()
Этот метод переводит поток в приостановленное состояние, он может быть возобновлен с помощью метода resume().

2

public void stop()
Этот метод полностью останавливает поток.

3

public void resume()
Этот метод возобновляет поток, который был приостановлен с помощью метода suspend().

4

public void wait()
Заставляет текущий поток ждать, пока другой поток не вызовет notify().

5

public void notify()
Пробуждает единственный поток, ожидающий на мониторе этого объекта.

Имейте в виду, что в последних версиях Java не рекомендуется использовать методы suspend(), resume() и stop(), поэтому вам следует использовать доступные альтернативы.

Пример


class RunnableDemo implements Runnable {
public Thread t;
private String threadName;
boolean suspended = false;

RunnableDemo( String name) {
threadName = name;
System.out.println("Создание " + threadName );
}

public void run() {
System.out.println("Выолнение " + threadName );
try {
for(int i = 10; i > 0; i--) {
System.out.println("Поток: " + threadName + ", " + i);
// Пусть поток немного подождет.
Thread.sleep(300);
synchronized(this) {
while(suspended) {
wait();
}
}
}
} catch (InterruptedException e) {
System.out.println("Поток " + threadName + " прерван.");
}
System.out.println("Поток " + threadName + " завершается.");
}

public void start () {
System.out.println("Запуск " + threadName );
if (t == null) {
t = new Thread (this, threadName);
t.start ();
}
}

void suspend() {
suspended = true;
}

synchronized void resume() {
suspended = false;
notify();
}
}

public class TestThread {

public static void main(String args[]) {

RunnableDemo R1 = new RunnableDemo( "Поток-1");
R1.start();

RunnableDemo R2 = new RunnableDemo( " Поток-2");
R2.start();

try {
Thread.sleep(1000);
R1.suspend();
System.out.println("Приостановка первого потока");
Thread.sleep(1000);
R1.resume();
System.out.println("Возобновление первого потока");

R2.suspend();
System.out.println("Приостановка второго потока");
Thread.sleep(1000);
R2.resume();
System.out.println("Возобновление второго потока");
} catch (InterruptedException e) {
System.out.println("Основной поток прерван");
}try {
System.out.println("Ожидание завершения потоков.");
R1.t.join();
R2.t.join();
} catch (InterruptedException e) {
System.out.println("Основной поток прерван");
}
System.out.println("Основной поток завершается.");
}
}
Вышеупомянутая программа производит следующий вывод:

Создание Поток-1
Запуск Поток-1
Создание Поток-2
Запуск Поток-2
Выполнение Поток-1
Поток: Поток-1, 10
Запуск Поток-2
Поток: Поток-2, 10
Поток: Поток-1, 9
Поток: Поток-2, 9
Поток: Поток-1, 8
Поток: Поток-2, 8
Поток: Поток-1, 7
Поток: Поток-2, 7
Приостановка первого потока
Поток: Поток-2, 6
Поток: Поток-2, 5
Поток: Поток-2, 4
Возобновление первого потока
Приостановка второго потока
Поток: Поток-1, 6
Поток: Поток-1, 5
Поток: Поток-1, 4
Поток: Поток-1, 3
Возобновление второго потока
Поток: Поток-2, 3
Ожидание завершения потоков.
Поток: Поток-1, 2
Поток: Поток -2, 2
Поток: Поток -1, 1
Поток: Поток -2, 1
Поток Поток-1 завершается.
Поток Поток-2 завершается.
Основной поток завершается.