interrupted():测试当前线程【运行此方法的当前线程】是否已经是中断状态,执行后具有将状态标志清除为false的功能。
isInterrupted():测试线程对象是否已经是中断状态,但不清除状态标志。
interrupted()的例子:
public static void main(String[] args) { try{ MyThread thread = new MyThread(); thread.start(); Thread.sleep(1000); thread.interrupt(); syso(thread.interrupted()); syso(thread.interrupted()); }catch(InterruptedException e) { e.printStackTrace(); } } //运行结果 false false
从上可以看出thread.interrupted()执行的是运行当前方法的线程,而不是thread线程,而由于main线程一直没有停止,所以一直是false。
public static void main(String[] args) { Thread.currentThread().interrupt(); syso(Thread.interrupted()); syso(Thread.interrupted()); } //运行结果 true false
从上可以看出Thread.currentTrhead().interrupt()将main线程停止了,所以下面第一个是true状态,而第二个是false状态,就是因为interrupted()方法有清空状态标志的功能。
isInterrupted()的例子:
public static void main(String[] args) { try{ MyThread thread = new MyThread(); thread.start(); Thread.sleep(1000); thread.interrupt(); syso(thread.isInterrupted()); syso(thread.isInterrupted()); }catch(InterruptedException e) { e.printStackTrace(); } } //运行结果 true true
从上面可以看出isInterrupted()就是线程对象是否中断。
interrupt()并不能真正的结束线程:
public class MyThread extends Thread{ public void run() { super.run(); for(int i = 0; i < 5; i++) { if(this.interrupted()) { System.out.println("已经是停止状态了!我要退出了!"); break; } System.out.println("i = " + i); } System.out.println("for之后代码"); } } public class Main { public static void main(String[] args) { try { MyThread thread = new MyThread(); thread.start(); Thread.sleep(2000); thread.interrupt(); } catch(InterruptedException e) { e.printStackTrace(); } System.out.println("结束了"); } }
运行结果:
可以发现interrupt()并没有真正终止线程。下面介绍几种可以终止线程的方法:
1.异常法【建议使用】:
if(this.interrupted()) { System.out.println("已经是停止状态了!我要退出了!"); throw new InterruptedException(); break; }
在上面需要正常终止的地方抛出异常即可。
此方法最推荐使用,因为在catch块中还可以将异常向上抛,使线程停止的事件得以传播。
2.在sleep中interrupt():
public class SleepThread extends Thread{ public void run() { super.run(); try { System.out.println("run begin"); Thread.sleep(200000); System.out.println("run end"); } catch(InterruptedException e) { System.out.println("沉睡中停止,进入catch"); e.printStackTrace(); } } } public class SleepMain { public static void main(String[] args) { try { SleepThread thread = new SleepThread(); thread.start(); Thread.sleep(200); thread.interrupt(); } catch(InterruptedException e) { System.out.println("main catch"); e.printStackTrace(); } System.out.println("结束了"); } }
运行结果:
3.使用作废的stop()方法:
调用stop()方法会强制让线程停止则有可能使一些清理性的工作得不到完成。并且有可能对锁定对象进行了“解锁”,导致数据得不到同步处理,出现数据不一致问题。
4.return法:
public class ReturnThread extends Thread{ public void run() { while(true) { if(this.isInterrupted()) { System.out.println("停止了!"); return; } System.out.println("timer" + System.currentTimeMillis()); } } } public class ReturnMain { public static void main(String[] args) throws InterruptedException { ReturnThread thread = new ReturnThread(); thread.start(); Thread.sleep(20); thread.interrupt(); } }
在需要停止的地方return即可。
原文地址:https://www.cnblogs.com/cing/p/8997582.html
时间: 2024-10-08 20:09:56