【365期】Java中如何终止运行中的线程？while(true){i++;}死循环是如何跳出的？

Java中 终止线程通常意味着在线程处理任务完成之前停掉正在做的操作，也就是放弃当前的操作。

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

• 使用退出标志，使线程正常退出，也就是当 run() 方法完成后线程中止。

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

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

使用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();
  
  //创建4个线程
  for (int i = 0; i < 4; i++) {
   Thread thread=new Thread(myRunable,i+"   ");
   thread.start();
   }
  //线程休眠
  Thread.sleep(2000L);
  System.out.println("——————————————————————————");
  //修改退出标志，使线程终止
  runnable.flag = false; 
 }
}

最后，运行结果，如下：

使用interrupt()中断的方式

需要明确的一点的是：interrupt() 方法并不像在 for 循环语句中使用 break 语句那样干脆，马上就停止循环。调用 interrupt() 方法仅仅是在当前线程中打一个停止的标记，并不是真的停止线程。

也就是说，线程中断并不会立即终止线程，而是通知目标线程，有人希望你终止。至于目标线程收到通知后会如何处理，则完全由目标线程自行决定。这一点很重要，如果中断后，线程立即无条件退出，那么我们又会遇到stop()方法的老问题。

事实上，如果一个线程不能被 interrupt，那么 stop 方法也不会起作用。

我们来看一个使用 interrupt() 的例子：

public class InterruptThread1 extends Thread{

    public static void main(String[] args) {
        try {
            InterruptThread1 t = new InterruptThread1();
            t.start();
            Thread.sleep(200);
            t.interrupt();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        super.run();
        for(int i = 0; i <= 200000; i++) {
            System.out.println("i=" + i);
        }
    }
    
}

从输出的结果我们会发现 interrupt 方法并没有停止线程 t 中的处理逻辑，也就是说即使 t 线程被设置为了中断状态，但是这个中断并不会起作用，那么该如何停止线程呢？

这就需要使用到另外两个与线程中断有关的方法了：

public boolean Thread.isInterrupted() //判断是否被中断
public static boolean Thread.interrupted() //判断是否被中断，并清除当前中断状态

这两个方法使得当前线程能够感知到是否被中断了（通过检查标志位）。

所以如果希望线程 t 在中断后停止，就必须先判断是否被中断，并为它增加相应的中断处理代码：

@Override
public void run() {
    super.run();
    for(int i = 0; i <= 200000; i++) {
        //判断是否被中断
        if(Thread.currentThread().isInterrupted()){
            //处理中断逻辑
            break;
        }
        System.out.println("i=" + i);
    }
}

输出结果，for 循环在执行完成前就提前结束了：

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

这种方式看起来与之前介绍的“使用标志位终止线程”非常类似，但是在遇到 sleep() 或者 wait() 这样的操作，我们只能通过中断来处理了。

public static native void sleep(long millis) throws InterruptedException

Thread.sleep() 方法会抛出一个 InterruptedException 异常，当线程被 sleep() 休眠时，如果被中断，这会就抛出这个异常。

注意：Thread.sleep() 方法由于中断而抛出的异常，是会清除中断标记的。

使用stop()中断

通过查看 JDK 的 API，我们会看到 java.lang.Thread 类型提供了一系列的方法如 start()、stop()、resume()、suspend()、destory()等方法来管理线程。但是除了 start() 之外，其它几个方法都被声名为已过时（deprecated）。

虽然 stop() 方法确实可以停止一个正在运行的线程，但是这个方法是不安全的，而且该方法已被弃用，最好不要使用它。

为什么弃用stop：

调用 stop() 方法会立刻停止 run() 方法中剩余的全部工作，包括在 catch 或 finally 语句中的，并抛出ThreadDeath异常(通常情况下此异常不需要显示的捕获)，因此可能会导致一些清理性的工作的得不到完成，如文件，数据库等的关闭。调用 stop() 方法会立即释放该线程所持有的所有的锁，导致数据得不到同步，出现数据不一致的问题。

例如，存在一个对象 u 持有 ID 和 NAME 两个字段，假如写入线程在写对象的过程中，只完成了对 ID 的赋值，但没来得及为 NAME 赋值，就被 stop() 导致锁被释放，那么当读取线程得到锁之后再去读取对象 u 的 ID 和 Name 时，就会出现数据不一致的问题，如下图：

while(true){i++;}死循环是如何跳出的

@Override
    public void run() {
        while (true){
            try {
                /**
                 * mBlockingQueue会在线程内声明如下
                 * private final BlockingQueue<String> mBlockingQueue;
                 * 线程初始化时会对mBlockingQueue赋值
                 * */
                String string = mBlockingQueue.take();
                Log.d("wuyazhouHttp","string: "+string);
            } catch (InterruptedException e) {//捕捉异常
                if (mQuit) {
                    Log.d("wuyazhouHttp","线程结束");
                    return;
                }
                Log.d("wuyazhouHttp","string: 阻塞列表为空");
                continue;
            }
        }
    }

public void quit() {
    mQuit = true;//更新标志位
    interrupt();//调用interrupt()方法中断阻塞并抛出一个异常
}

首先会更新标志位可以结束线程，其次调用interrupt()方法中断阻塞并抛出一个异常，然后就能调用第二段代码中的return以终止进程

感谢阅读，希望对你有所帮助 :) 

来源：blog.csdn.net/rootkiss/article/details/101596379