Демонстрация работы нестатического метода thread.isInterrupted() - читает значение флага прерывания, не очищая его. После того, как флаг прерывания установлен, он остается выставленным неограниченно долго
public class InterruptExample_0_isInterrupted {
public static void main(String[] args) throws InterruptedException {
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
Thread myThread = Thread.currentThread();
while (true) {
System.out.println(myThread.isInterrupted());
for (long k = 0; k < 1_000_000_000L; k++) ;
}
}
});
thread.start();
Thread.sleep(1000);
thread.interrupt();
}
}
>> false
>> false
>> false
>> true
>> true
>> true
>> true
... дальше только true
Демонстрация работы статического метода Thread.interrupted() - читает значение флага прерывания, очищая его. Т.е. первое же чтение очищает флаг
public class InterruptExample_1_interrupted {
public static void main(String[] args) throws InterruptedException {
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
while (true) {
System.out.println(Thread.interrupted());
for (long k = 0; k < 1_000_000_000L; k++) ;
}
}
});
thread.start();
Thread.sleep(1000);
thread.interrupt();
}
}
>> false
>> false
>> false
>> true
>> false
>> false
>> false
... дальше только false
Демонстрация передачи сигнала о прерывании одного потока - другому
public class InterruptExample_2_isInterrupted_while {
public static void main(String[] args) throws InterruptedException {
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
Thread myThread = Thread.currentThread();
while (!myThread.isInterrupted()) {
System.out.println("Hello!");
for (long k = 0; k < 1_000_000_000L; k++) ;
}
}
});
thread.start();
Thread.sleep(1000);
thread.interrupt();
}
}
>> Hello!
>> Hello!
>> Hello!
Демонстрация передачи сигнала о прерывании одного потока - другому, при этом не только выставляется флаг прерывания (доступный для чтения по isInterrupted()), но и
1) попытка войти в метод sleep() с выставленным флагом
2) или изменение состояния флага когда метод спит (sleep())
приводит к выбрасыванию InterruptedException
public class InterruptExample_3_sleep_while {
public static void main(String[] args) throws InterruptedException {
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
Thread myThread = Thread.currentThread();
while (!myThread.isInterrupted()) {
System.out.println("Hello!");
try {
Thread.sleep(200);
} catch (InterruptedException e) {
System.out.println("I interrupted: by exception");
return;
}
}
System.out.println("I interrupted: by flag");
}
});
thread.start();
Thread.sleep(1000);
thread.interrupt();
}
}
>> Hello!
>> Hello!
>> Hello!
>> Hello!
>> Hello!
>> I interrupted: by exception
wait() ведет себя аналогично sleep()
public class InterruptExample_4_wait_while {
public static void main(String[] args) throws InterruptedException {
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
Object lock = new Object();
Thread myThread = Thread.currentThread();
while (!myThread.isInterrupted()) {
System.out.println("Hello!");
try {
synchronized (lock) {
lock.wait(200);
}
} catch (InterruptedException e) {
System.out.println("I interrupted: by exception");
return;
}
}
System.out.println("I interrupted: by flag");
}
});
thread.start();
Thread.sleep(1000);
thread.interrupt();
}
}
Неправильная остановка потока с помощью нереализованного destroy()
public class InterruptExample_5_destroy_while {
public static void main(String[] args) throws InterruptedException {
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
while (true) {
System.out.println("Hello!");
for (long k = 0; k < 1_000_000_000L; k++) ;
}
}
});
thread.start();
Thread.sleep(1000);
thread.destroy();
}
}
>> Hello!
>> Hello!
>> Hello!
>> Exception in thread "main" java.lang.NoSuchMethodError
>> Hello!
>> Hello!
>> Hello!
... дальше "Hello!"
Неправильная остановка потока с помощью stop()
public class InterruptExample_6_stop_while {
public static void main(String[] args) throws InterruptedException {
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
while (true) {
System.out.println("Hello!");
for (long k = 0; k < 1_000_000_000L; k++) ;
}
}
});
thread.start();
Thread.sleep(1000);
thread.stop();
}
}
>> Hello!
>> Hello!
>> Hello!
Неправильная приостановка потока с помощью suspend()/resume()
public class InterruptExample_7_suspend_while {
public static void main(String[] args) throws InterruptedException {
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
while (true) {
System.out.println("Hello!");
for (long k = 0; k < 1_000_000_000L; k++) ;
}
}
});
thread.start();
Thread.sleep(1000);
thread.suspend();
Thread.sleep(1000);
thread.resume();
}
}
Классическая статья от Sun, в которой объяснено, почему destroy()/stop()/suspend()/resumr() - это зло = "Why Are Thread.stop, Thread.suspend, Thread.resume and Runtime.runFinalizersOnExit Deprecated?"
