菜单 学习猿地 - LMONKEY

VIP

开通学习猿地VIP

尊享10项VIP特权 持续新增

知识通关挑战

打卡带练!告别无效练习

接私单赚外块

VIP优先接,累计金额超百万

学习猿地私房课免费学

大厂实战课仅对VIP开放

你的一对一导师

每月可免费咨询大牛30次

领取更多软件工程师实用特权

入驻
117
0

面试阿里,字节跳动,腾讯90%都会被问到如何终止线程?有几种方式?那么你都知道吗?

原创
05/13 14:22
阅读数 39176

在 Java 中有以下 3 种方法可以终止正在运行的线程:

使用退出标志,使线程正常退出,也就是当 run() 方法完成后线程终止;
使用 stop() 方法强行终止线程,但是不推荐使用这个方法,因为使用此方法不安全,目前该方法已被弃用;
使用 interrupt()方法中断线程。

第一种:使用标志位终止线程

使用标志位终止线程就是定义一个boolean型的标志位 ,在线程的run方法中根据这个标志位是为true还是为false来判断是否终止,这种情况多用于while循环中。

class StopThread extends Thread {
    //标志位
    private boolean flag = true;

    @Override
    public synchronized void run() {
        while (flag) {
            System.out.println(Thread.currentThread().getName()+"---我是子线程");
        }
    }

    /**
     * @methodDesc: 功能描述:(终止线程)
     */
    public void stopThread() {
        flag = false;
        System.out.println(getName()+"线程被终止掉了");
    }
}

/**
 @classDesc: 功能描述:(演示终止线程效果)
 */
public class StopThreadDemo {

    public static void main(String[] args) {
        StopThread stopThread1 = new StopThread();
        StopThread stopThread2 = new StopThread();
        stopThread1.start();
        stopThread2.start();

        for (int i = 0; i < 50; i++) {
            System.out.println("------我是主线程-----"+i);
            if(i==30) {
                stopThread1.stopThread();
                stopThread2.stopThread();
            }
        }
    }
}

  

第二种: 使用 stop() 终止线程(不安全)

虽然使用stop() 方法可以停止一个正在运行的线程,但是这个方法是不安全的,而且该方法已被弃用。
弃用stop()方法的原因:

调用 stop() 方法会立刻停止 run() 方法中剩余的全部任务,包括在 catch 或 finally 语句中的,并抛出ThreadDeath异常,因此可能会导致任务执行失败。
调用 stop() 方法会立即释放该线程所持有的所有的锁,导致数据得不到同步,出现数据不一致的问题。拿银行转账作为例子,从A账户向B账户转账100元,这一过程分为三步,第一步是从A账户中减去100元,假如这时线程就被stop了,那么这个线程就会释放它所取得锁,然后其他的线程在获取到它所释放的锁以后就会继续执行,这样A账户就少了100元,而B账户也没有收到这100元,就会导致数据不一致。这就是stop方法的不安全性。

第三种: 使用interrupt方法中断线程

使用 interrupt() 方法中断线程时并不会立即终止线程,而是通知目标线程,告诉它有人希望你终止。至于目标线程收到通知后会如何处理,则完全由目标线程自行决定。理解这一点很重要,如果中断后,线程立即无条件退出,那么就会和 stop() 方法没有任何区别,会导致线程不安全问题。

首先我们先来看一个使用 interrupt() 中断线程的例子:

public class InterruptThread extends Thread{
    
    @Override
    public void run() {
        for(int i = 0; i <= 10000; i++) {
            System.out.println("i=" + i);
        }
    }
    
    public static void main(String[] args) {
        try {
            InterruptThread interruptThread = new InterruptThread();
            interruptThread.start();
            Thread.sleep(100);
            interruptThread.interrupt();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    } 
}

  

运行结果如下:

 

 

从输出的结果可以发现调用 interrupt 方法并没有停止掉线程interruptThread中的处理逻辑,也就是说即使线程被设置为了中断状态,但是这个中断并没有起到任何作用,那么怎样才能停止线程呢?

这就需要使用到 isInterrupted() 方法了:

public boolean Thread.isInterrupted() //判断是否被中断

 

所以如果希望线程在中断后停止,就应该先判断线程是否被中断,然后在执行中断处理代码:

public class InterruptThread extends Thread{
    
    @Override
    public void run() {
        for(int i = 0; i <= 10000; i++) {
            //判断是否被中断
            if(Thread.currentThread().isInterrupted()){
                //处理中断
                break;
            }
            System.out.println("i=" + i);
        }
    }
    
    public static void main(String[] args) {
        try {
            InterruptThread interruptThread = new InterruptThread();
            interruptThread.start();
            Thread.sleep(100);
            interruptThread.interrupt();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    } 
}

  

运行结果:

 

 

在上面这段代码中,我们增加了 Thread.isInterrupted() 来判断当前线程是否被中断了,如果线程被中断,则退出 for 循环,结束线程。

总结:看完如果有什么不懂的欢迎在下方留言评论

发表评论

0/200
117 点赞
0 评论
收藏