欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

详解Java停止线程的四种方法

程序员文章站 2022-03-21 11:01:06
一、线程停止基础知识 interrupted(): 测试当前线程是否已经中断。该方法为静态方法,调用后会返回boolean值。不过调用之后会改变线程的状态,如果是中断状态调用的,调用之后会清除线...

一、线程停止基础知识

  • interrupted(): 测试当前线程是否已经中断。该方法为静态方法,调用后会返回boolean值。不过调用之后会改变线程的状态,如果是中断状态调用的,调用之后会清除线程的中断状态。
  • isinterrupted(): 测试线程是否已经中断。该方法由对象调用
  • interrupt(): 标记线程为中断状态,不过不会中断正在运行的线程。
  • stop(): 暴力停止线程。已弃用。

二、停止线程方法1:异常法停止

   线程调用interrupt()方法后,在线程的run方法中判断当前对象的interrupted()状态,如果是中断状态则抛出异常,达到中断线程的效果。

   如下示例:

mythread.java

public class mythread extends thread {

    @override
    public void run() {
        try {
            for (int i = 0; i < 500000; i++) {
                if (mythread.interrupted()){
                    system.out.println("已经是停止状态了,我要退出了!");
                    throw new interruptedexception();
                }
                system.out.println("i = " + (i+1));
            }

            system.out.println("如果我被输出了,则代表线程没有停止");
        } catch (interruptedexception e) {
            system.out.println("在mythread类中的run方法中被捕获");
            e.printstacktrace();
        }
    }
}

main.java

/**
 * 根据中断状态退出for循环
 * @author: xjf
 * @date: 2019/5/25 13:27
 */
public class main {

    public static void main(string[] args) {
        try {
            mythread mythread  = new mythread();
            mythread.start();
            thread.sleep(100);
            mythread.interrupt();
        } catch (interruptedexception e) {
            e.printstacktrace();
        }

        system.out.println("end!");
    }
}

结果如下:
i = 19115
i = 19116
i = 19117
i = 19118
i = 19119
end!

已经是停止状态了,我要退出了!
在mythread类中的run方法中被捕获
java.lang.interruptedexception
 at com.book.interrupt_exit.mythread.run(mythread.java:15)

process finished with exit code 0

三、停止线程方法2:在沉睡中停止

先将线程sleep,然后调用interrupt标记中断状态,interrupt会将阻塞状态的线程中断。会抛出中断异常,达到停止线程的效果。如下示例:

mythread.java

public class mythread extends thread {

    @override
    public void run() {
        try {
            system.out.println("run-----------start");
            thread.sleep(5000);
            system.out.println("run-----------end");
        } catch (interruptedexception e) {
            system.out.println("在沉睡中被停止!进入catch,线程的是否处于停止状态:" + this.isinterrupted());
            e.printstacktrace();
        }

    }
}

main.java

public class main {

    public static void main(string[] args) {
        try {
            mythread mythread = new mythread();
            mythread.start();
            thread.sleep(2000);
            system.out.println("状态:"+mythread.interrupted());
            mythread.interrupt();
        } catch (interruptedexception e) {
            e.printstacktrace();
        }
    }
}

结果
run-----------start
状态:false
java.lang.interruptedexception: sleep interrupted
在沉睡中被停止!进入catch,线程的是否处于停止状态:false
 at java.lang.thread.sleep(native method)
 at com.book.sleep_interrupt.mythread.run(mythread.java:13)

线程先调用interrupt标记中断状态,然后线程再睡眠。会抛出中断异常,达到停止线程的效果。如下:

mythread1.java

public class mythread1 extends thread {

    @override
    public void run() {
        try {

            for (int i = 0; i < 100000; i++) {
                system.out.println("i = " + (i+1));
            }
            system.out.println("run begin");
            //interrupt是做一个中断标记,当时不会去中断正在运行的线程,当该线程处于阻塞状态时就会进行中断
            //因此,先进行interrupt后,再遇到sleep阻塞时,才会进行中断
            thread.sleep(200000);
            system.out.println("run end");

        } catch (interruptedexception e) {
            system.out.println("先停止,再遇到了sleep! 进入catch!");
            e.printstacktrace();
        }
    }
}

main1.java

public class main1 {

    public static void main(string[] args) {

        mythread1 mythread1 = new mythread1();
        mythread1.start();
        mythread1.interrupt();
        system.out.println("end!");
    }
}

结果:
i = 99993
i = 99994
i = 99995
i = 99996
i = 99997
i = 99998
i = 99999
i = 100000
run begin

先停止,再遇到了sleep! 进入catch!
java.lang.interruptedexception: sleep interrupted
 at java.lang.thread.sleep(native method)
 at com.book.sleep_interrupt.mythread1.run(mythread1.java:19)

四、停止线程方法3:stop()暴力停止

线程调用stop()方法会被暴力停止,方法已弃用。该方法会有不好的后果:

  1. 强制让线程停止有可能使一些请理性的工作得不到完成。
  2. 对锁定的对象进行了“解锁”,导致数据得不到同步的处理,出现数据不一致的问题(比如一个方法加上了synchronized,并在其中进行了一个长时间的处理,而在处理结束之前该线程进行了stop(),则未完成的数据将没有进行到同步的处理)

五、停止线程方法4:使用return停止线程

调用interrupt标记为中断状态后,在run方法中判断当前线程状态,如果为中断状态则return,能达到停止线程的效果。

备注:建议使用“抛异常”的方法来实现线程的停止,因为在catch块中还可以将异常向上抛,使线程停止的事件得以传播

参考:《java多线程编程核心技术》

到此这篇关于详解java停止线程的四种方法的文章就介绍到这了,更多相关java停止线程内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持!

相关标签: Java 停止线程