Java多线程与并发 --- interrupt 函数

interrupt 函数

如何中断线程？

已经被抛弃的方法：
一、通过调用 stop（）方法停止线程

stop 太过于暴力且不安全的，使得被停止的线程来不及清理，会马上释放锁，引发数据不同步的问题

二、suspend（） 方法 resume （）方法

目前使用的方法：

一、interrupt （），通知线程应该中断了

 

1. public class InterruptDemo {
2. public static void main(String[] args) throws InterruptedException {
3. Runnable interruptTask = new Runnable() {
4. @Override
5. public void run() {
6. int i = 0;
7. try {
8. //在正常运行任务时，经常检查本线程的中断标志位，如果被设置了中断标志就自行停止线程
9. while (!Thread.currentThread().isInterrupted()) {
10. Thread.sleep(100); // 休眠100ms
11. i++;
12. System.out.println(Thread.currentThread().getName() + " (" + Thread.currentThread().getState() + ") loop " + i);
13. }
14. } catch (InterruptedException e) {
15. //在调用阻塞方法时正确处理InterruptedException异常。（例如，catch异常后就结束线程。）
16. System.out.println(Thread.currentThread().getName() + " (" + Thread.currentThread().getState() + ") catch InterruptedException.");
17. }
18. }
19. };
20. Thread t1 = new Thread(interruptTask, "t1");
21. System.out.println(t1.getName() +" ("+t1.getState()+") is new.");
22.  
23. t1.start(); // 启动“线程t1”
24. System.out.println(t1.getName() +" ("+t1.getState()+") is started.");
25.  
26. // 主线程休眠300ms，然后主线程给t1发“中断”指令。
27. Thread.sleep(300);
28. t1.interrupt();
29. System.out.println(t1.getName() +" ("+t1.getState()+") is interrupted.");
30.  
31. // 主线程休眠300ms，然后查看t1的状态。
32. Thread.sleep(300);
33. System.out.println(t1.getName() +" ("+t1.getState()+") is interrupted now.");
34. }
35. }