您现在的位置是:首页 > 文章详情

Java多线程-线程中止

日期:2019-08-26点击:400

不正确的线程中止-Stop

Stop:中止线程,并且清除监控器锁的信息,但是可能导致
线程安全问题,JDK不建议用。
Destroy: JDK未实现该方法。

/** * @author simon */ public class StopThread extends Thread { private int i = 0, j = 0; @Override public void run() { synchronized (this) { // 增加同步锁,确保线程安全 ++i; try { // 休眠10秒,模拟耗时操作 Thread.sleep(10000); } catch (InterruptedException e) { e.printStackTrace(); } ++j; } } /** * 打印i和j */ public void print() { System.out.println("i=" + i + " j=" + j); } }
/** * @author simon * 示例3 - 线程stop强制性中止,破坏线程安全的示例 */ public class Demo { public static void main(String[] args) throws InterruptedException { StopThread thread = new StopThread(); thread.start(); // 休眠1秒,确保i变量自增成功 Thread.sleep(1000); // 暂停线程 thread.stop(); // 错误的终止 //thread.interrupt(); // @正确终止 while (thread.isAlive()) { // 确保线程已经终止 } // 输出结果 thread.print(); } }

理想状态:要么自增成功i=1, j=1,要么自增失败i=0, j=0
真正程序执行结果:i=1, j=0

没有保证同步代码块里面数据的一致性,破坏了线程安全
stop方法直接停止线程

正确的线程中止-interrupt

如果目标线程在调用Object class的wait()、wait(long)或wait(long, int)方法、join()、join(long, int)或sleep(long, int)方法时被阻塞,那么Interrupt会生效,该线程的中断状态将被清除,抛出InterruptedException异常。

如果目标线程是被I/O或者NIO中的Channel所阻塞,同样,I/O操作会被中断或者返回特殊异常值。达到终止线程的目的。

如果以上条件都不满足,则会设置此线程的中断状态。

对Demo中的示例,stop()改成interrupt()后,最终输出为"i=1 j=1",数据一致。

正确的线程中止-标志位

/** 通过状态位来判断 */ public class Demo4 extends Thread { public volatile static boolean flag = true; public static void main(String[] args) throws InterruptedException { new Thread(() -> { try { while (flag) { // 判断是否运行 System.out.println("程序运行中"); Thread.sleep(1000L); } } catch (InterruptedException e) { e.printStackTrace(); } }).start(); // 3秒之后,将状态标志改为False,代表不继续运行 Thread.sleep(3000L); flag = false; System.out.println("程序运行结束"); } }

在上方代码逻辑中,增加一个判断,用来控制线程执行的中止。

原文链接:https://yq.aliyun.com/articles/715961
关注公众号

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。

持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。

文章评论

共有0条评论来说两句吧...

文章二维码

扫描即可查看该文章

点击排行

推荐阅读

最新文章