如何优雅地中止线程?

本文来学习如何学习优雅地中止线程?通过 Java 线程的生老病死的学习,我相信大家对线程的运行以及线程的状态有一定了解了,那么我们现在来学习中止线程:

错误的线程中止 - stop

首先来讲解一个错误的方式来中止线程 — stop:中止线程,并且清除监控器锁的信息,但是可能导致线程安全问题,JDK 不建议使用,类似的方法还有 destory,由于 JDK 从未实现该方法,在这里就不介绍了。

接下来通过一段程序来讲解为什么 stop 会导致线程安全问题?

首先定义一个线程类 StopThread

public class StopThread extends Thread {
    private int i = 0;
    private int 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);
    }
}

这个线程做的事情就是在同步代码块中对 ij 这两个变量进行自增操作,但是在这个执行过程中会进行 10 秒的睡眠,如果在这个过程中,如果用 stop 方法将线程中止的话,会导致 ij 数据不正确,也可以说程序设计上的线程安全问题,因为主线程影响到了创建的 StopThread 线程的数据不正确性,理想的正确输出结果应该是要么全部添加成功,要么都失败,因为我们添加锁的目的就是保证操作原子性或者说想让这两个变量在操作的时候不受其他线程干扰。

下面编写 StopThreadDemo 类,来使用 stop 方法做个错误示范:

public class StopThreadDemo {
    public static void main(String[] args) throws InterruptedException {
        StopThread thread = new StopThread();
        thread.start();
        // 休眠 1 秒,确保 i 变量自增成功
        Thread.sleep(1000);
        // 暂停线程
        thread.stop(); // 错误的终止
        while (thread.isAlive()) {
            // 确保线程已经终止
        } // 输出结果
        thread.print();
    }
}

StopThreadDemo 类中,创建并启动了 StopThread 线程,这个线程就是下执行变量 ij 的自增操作,但是这个自增操作是用同步关键字包裹的同步代码块,这样做是为了让两个变量的自增操作实现原子性,不会受到其他线程的干扰,确保线程的安全。

但是在线程休眠的 10 秒内,通过 stop 方法把线程中止掉,会发现输出结果为 i=1 j=0,也就是代码的前半段 i 自增实现,但是后半段 j 的自增失败,会使线程中的数据出现不一致性,从而同步代码块的保证的原子性的目标没有达成,破坏了线程安全。

正确的线程中止 - interrupt

在介绍了错误的中止方式后,让我们来学习正确的线程中止 - interrupt

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

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

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

接下来将 StopThreadDemo 中的 stop 改为 interrupt 来看下运行结果是什么:

java.lang.InterruptedException: sleep interrupted
    at java.lang.Thread.sleep(Native Method)
    at com.wupx.thread.StopThread.run(StopThread.java:18)
i=1 j=1

可以发现两个变量的自增可以正常执行,保证了执行的数据一致性,interrupt 不会强制中止,将线程直接中断,而是抛出异常通知我们,开发者就可以控制收到异常后的执行逻辑,让整个程序处于线程安全的状态,这是目前 JDK 版本中推荐的 interrupt 方法。

除了 interrupt 的正确方法外,还可以通过标志位的形式来中止线程:

正确的线程中止 - 标志位

如果代码程序逻辑中是循环执行的业务,可以在程序的执行中线程代码中增加一个标志位,比如下面代码中在 while 循环中去执行这个程序,通过 flag 去控制程序是否继续执行,如果在外部线程将 flag 修改为 false,那么创建的子线程代码中会收到这个数据的变化,通过这个变量的形式,通知到另一个线程,从而达到控制线程中止的效果。

public class FlagThreadDemo {
    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("程序运行结束");
    }
}

通过运行代码,得到的结果如下:

运行中
运行中
运行中
程序运行结束

这种方式受限于线程中所执行的业务逻辑,如果程序中是有可以用来做标志位的条件的话可以用这种方式来做,也是一种正确的线程中止方式。

总结

本文主要讲解了线程中止的三种方式:stopinterrupt 以及标志位,大家学会了吗,欢迎留言讨论。

源代码可以在公众号【武培轩】中回复【并发】获取。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 205,132评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,802评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,566评论 0 338
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,858评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,867评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,695评论 1 282
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,064评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,705评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 42,915评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,677评论 2 323
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,796评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,432评论 4 322
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,041评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,992评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,223评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,185评论 2 352
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,535评论 2 343

推荐阅读更多精彩内容