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

Java中终止线程的方法详解

程序员文章站 2024-02-24 17:30:16
java中终止线程的方式主要有三种: 1、使用stop()方法,已被弃用。原因是:stop()是立即终止,会导致一些数据被到处理一部分就会被终止,而用户并不知道哪些数...

java中终止线程的方式主要有三种:

1、使用stop()方法,已被弃用。原因是:stop()是立即终止,会导致一些数据被到处理一部分就会被终止,而用户并不知道哪些数据被处理,哪些没有被处理,产生了不完整的“残疾”数据,不符合完整性,所以被废弃。so, forget it!

2、使用volatile标志位

看一个简单的例子:

首先,实现一个runnable接口,在其中定义volatile标志位,在run()方法中使用标志位控制程序运行

public class myrunnable implements runnable { 

 //定义退出标志,true会一直执行,false会退出循环 
 //使用volatile目的是保证可见性,一处修改了标志,处处都要去主存读取新的值,而不是使用缓存 
 public volatile boolean flag = true; 

 public void run() { 
  system.out.println("第" + thread.currentthread().getname() + "个线程创建"); 

  try { 
   thread.sleep(1000l); 
  } catch (interruptedexception e) { 
   e.printstacktrace(); 
  } 

  //退出标志生效位置 
  while (flag) { 
  } 
  system.out.println("第" + thread.currentthread().getname() + "个线程终止"); 
 } 
}

然后,在main()方法中创建线程,在合适的时候,修改标志位,终止运行中的线程。

public class treadtest { 
 public static void main(string[] arg) throws interruptedexception { 
  myrunnable runnable = new myrunnable(); 

  //创建3个线程 
  for (int i = 1; i <= 3; i++) { 
   thread thread = new thread(runnable, i + ""); 
   thread.start(); 
  } 
  //线程休眠 
  thread.sleep(2000l); 
  system.out.println("——————————————————————————"); 
  //修改退出标志,使线程终止 
  runnable.flag = false; 
 } 
}

最后,运行结果,如下:

第1个线程创建
第2个线程创建
第3个线程创建
--------------------------
第3个线程终止
第1个线程终止
第2个线程终止

3、使用interrupt()中断的方式,注意使用interrupt()方法中断正在运行中的线程只会修改中断状态位,可以通过isinterrupted()判断。如果使用interrupt()方法中断阻塞中的线程,那么就会抛出interruptedexception异常,可以通过catch捕获异常,然后进行处理后终止线程。有些情况,我们不能判断线程的状态,所以使用interrupt()方法时一定要慎重考虑。

第一种:正在运行中终止

public class mythread extends thread {
 public void run(){
  super.run();
  try {
   for(int i=0; i<500000; i++){
    if(this.interrupted()) {
     system.out.println("线程已经终止, for循环不再执行");
      throw new interruptedexception();
    }
    system.out.println("i="+(i+1));
   }

   system.out.println("这是for循环外面的语句,也会被执行");
  } catch (interruptedexception e) {
   system.out.println("进入mythread.java类中的catch了。。。");
   e.printstacktrace();
  }
 }
}

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

运行结果如下:

...
i=203798
i=203799
i=203800
线程已经终止, for循环不再执行
进入mythread.java类中的catch了。。。
java.lang.interruptedexception
 at thread.mythread.run(mythread.java:13)

第二种:阻塞状态(sleep,wait等)终止

public class mythread extends thread {
 public void run(){
  super.run();

  try {
   system.out.println("线程开始。。。");
   thread.sleep(200000);
   system.out.println("线程结束。");
  } catch (interruptedexception e) {
   system.out.println("在沉睡中被停止, 进入catch, 调用isinterrupted()方法的结果是:" + this.isinterrupted());
   e.printstacktrace();
  }

 }
}

线程开始。。。
在沉睡中被停止, 进入catch, 调用isinterrupted()方法的结果是:false
java.lang.interruptedexception: sleep interrupted
 at java.lang.thread.sleep(native method)
 at thread.mythread.run(mythread.java:12)

从打印的结果来看, 如果在sleep状态下停止某一线程,会进入catch语句,并且清除停止状态值,使之变为false。

前一个实验是先sleep然后再用interrupt()停止,与之相反的操作在学习过程中也要注意:

public class mythread extends thread {
 public void run(){
  super.run();
  try {
   system.out.println("线程开始。。。");
   for(int i=0; i<10000; i++){
    system.out.println("i=" + i);
   }
   thread.sleep(200000);
   system.out.println("线程结束。");
  } catch (interruptedexception e) {
    system.out.println("先停止,再遇到sleep,进入catch异常");
   e.printstacktrace();
  }

 }
}

public class run {
 public static void main(string args[]){
  thread thread = new mythread();
  thread.start();
  thread.interrupt();
 }
}

运行结果:

i=9998
i=9999
先停止,再遇到sleep,进入catch异常
java.lang.interruptedexception: sleep interrupted
 at java.lang.thread.sleep(native method)
 at thread.mythread.run(mythread.java:15)

感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!