在Java中如何用interrupt优雅的结束线程

Posted 2023-02-23 warmor

    一般来说线程执行完run()之后就自动结束了，不过有些时候我们需要线程不停的做一些事情，也就是使用while循环，那么这时候该如何停止线程呢？

    这个问题需要分情况来讨论，如果线程做的事情不是耗时的，那么只需要使用一个标志即可，具体的代码如下：

 class MyThread extends Thread   	  
        private volatile boolean isStop = false;    
        public void run() 
        	while (!isStop) 
    			System.out.println("do something");
    		
        
        public void setStop() 
    		isStop = true;
    	      

    如果需要退出时，调用setStop()即可。这里使用了一个Java关键字volatile，这个关键字的目的是如果修改了isStop的值，那么在while循环中可以立即读取到修改后的值，关于volatile的详细介绍可以参考我的另一篇博文 java线程同步volatile与synchronized

    如果线程做的事情是耗时或者说阻塞的（如调用了sleep，同步锁的wait，socket的receiver，accept等方法），那么就需要用到interrupt()了，调用该函数时会把线程设置为中断状态。如果是sleep，wait则会抛出InterruptedException异常，代码中通过捕获该异常，然后break出循环，就可以了。代码如下：

public static void main(String[] args) 
  Thread t1 = new Thread(new Runnable() 

    @Override
    public void run() 
      System.out.println("t1 run...");
      int i = 0;
      //location 2
      while (Thread.currentThread().isInterrupted() == false) 

        System.out.println("i is " + i);
        i++;
        try 
    					
          Thread.sleep(1000);
         catch (InterruptedException e) 
    	  System.out.println("this is InterruptedException");
          break; //location 1
        
      
      boolean isInterrupted = Thread.currentThread().isInterrupted();
      System.out.println("thread is interrupt ? " + isInterrupted);
    
  );
  t1.start();
  System.out.println("main run...");
  try 
    Thread.sleep(10);
   catch (InterruptedException e) 
    e.printStackTrace();
  
  t1.interrupt();

    程序很简单，运行后，启动t1线程，然后主线程sleep 10毫秒，接着执行interrupt，让t1处于中断状态。结果打印如下：

main run...
t1 run...
i is 0
this is InterruptedException
thread is interrupt ? false

    因为执行了interrupt，而t1正处于sleep状态，所以会抛出 InterruptedException 异常，捕获异常后执行break就可以跳出while循环，这样线程就可以结束了。这里需要注意的是，捕获异常的同时，程序会把线程的中断状态重置，所以下面判断的结果为false。如果这里（location 1）不执行break，那么while循环会一直执行下去。

    下面来看看 isInterrupted（）和 interrupted（）的区别，代码如下：

public static void main(String[] args)
  
  Thread t1 = new Thread(new Runnable() 

    @Override
    public void run() 
      System.out.println("t1 run...");
      int i = 0;
      //location 2
      while (Thread.currentThread().isInterrupted() == false) 

        System.out.println("i is " + i);
        i++;
      
      boolean isInterrupted = Thread.currentThread().isInterrupted();
      System.out.println("thread is interrupt ? " + isInterrupted);
    
  );
  t1.start();
  System.out.println("main run...");
  try 
    Thread.sleep(10);
   catch (InterruptedException e) 
    e.printStackTrace();
  
    t1.interrupt();

    这里，先启动线程t1，然后主线程sleep 10毫秒，接着执行t1的interrupt函数。结果打印如下：

main run...
t1 run...
i is 0
i is 1

。。。

i is 305
i is 306
thread is interrupt ? true

    这很容易理解，一开始t1会一直打印，直到执行了interrupt，线程就会处于中断状态，那么while的条件就不满足了，所以会跳出循环。这种情况可以用在程序不抛出 InterruptedException 异常时结束线程。

    如果把location 2处的判断条件改为 Thread.interrupted() == false ，那么会出现什么情况呢？看看打印吧！

main run...
t1 run...
i is 0

。。。

i is 372
i is 373
thread is interrupt ? false

    前面的打印都一样，只是在打印线程的状态时，出现了差别。这是什么原因呢？ 原来isInterrupted（）和interrupted（）都可以判断线程的状态，所不同的是，interrupted（）在判断完之后会把线程的状态重置，所以后面再次判断时，线程就不处于中断状态了。

    其实还有一个办法那就是使用thread.stop()来强行终止线程，不过由于该方法不安全已经废弃掉了，因为他有下面两个缺陷：

1. 立即抛出ThreadDeath异常，在线程的run()方法内，任何一点都有可能抛出ThreadDeath异常，包括在catch或finally语句中。

2. 释放该线程所持有的所有的锁。

    好了，关于线程如何停止的问题到这里就圆满收官了，大家有什么问题欢迎留言讨论哈