JAVA进阶之路-Thread中的中断方法

Posted 2022-09-20 LuckyZhouStar

Thread的中断标识位

首先，一个线程不应该由其他线程来强制中断或停止，而是应该由线程自己自行停止。所以，Thread.stop, Thread.suspend, Thread.resume 都已经被废弃了。而 Thread.interrupt 的作用其实也不是中断线程，而是「通知线程应该中断了」，具体到底中断还是继续运行，应该由被通知的线程自己处理。具体来说，当对一个线程，调用 interrupt() 时，① 如果线程处于被阻塞状态（例如处于sleep, wait, join 等状态），那么线程将立即退出被阻塞状态，并抛出一个InterruptedException异常。仅此而已。② 如果线程处于正常活动状态，那么会将该线程的中断标志设置为 true，仅此而已。被设置中断标志的线程将继续正常运行，不受影响。interrupt() 并不能真正的中断线程，需要被调用的线程自己进行配合才行。也就是说，一个线程如果有被中断的需求，那么就可以这样做。① 在正常运行任务时，经常检查本线程的中断标志位，如果被设置了中断标志就自行停止线程。② 在调用阻塞方法时正确处理InterruptedException异常。（例如，catch异常后就结束线程。）

 /**
     * 功能描述:
     *
     * 介绍: Thread的interrupt方法
     * 调用interrupt(),通知线程应该中断了
     * 1.如果该线程处于阻塞状态，那么线程将立即退出阻塞状态，并抛出一个interruptedException异常，并且会清除该标志位，还是false，例如处于sleep、wait，join等状态，会抛出该异常
     * 2.如果线程处于正常活动状态，那么就会将该线程的中断标志位设置为true，被设置为true的中断标志位不影响该线程的正常运行
     *
     * 使用: Thread的interrupt方法
     * 需要被调用的线程配合中断
     * 1.在正常运行任务时，经常检查本线程的中断标志位，如果被设置了中断标志位就自行停止线程
     *
     * 2.如果线程处于正常状态，那么就会将该线程的中断标志位设置为true，被设置为true的中断标志位不影响该线程的正常运行
     */

    public void interruptedTest() 

    

代码示例

package basic.thread;

/**
 * @Author:chaoqiang.zhou
 * @Description:对非阻塞中的线程中断的Demo:
 * @Date:Create in 10:44 2018/3/1
 */
public class InterruptedThread extends Thread 


  //非阻塞，因为该线程执行的方法里面没有调用object的阻塞方法，所以只是改变标志位
  //但是如果调用了await的方法，就会抛出一个中断的异常，进行标志位的清除，详情看example3的信息
  @Override
  public void run() 
    while (true) 
      if (Thread.currentThread().isInterrupted()) 
        //false状态
        System.out.println("Someone interrupted me.");
       else 
        System.out.println("Thread is Going...");
      
      try 
        Thread.sleep(3000l);
       catch (InterruptedException e) 

        //在这里会立马的清除标志位的信息，还是为false
        System.out.println("current thread status is"+Thread.currentThread().isInterrupted());
      
    
  

  /**
   *
   * 把握几个重点：stop变量、run方法中的sleep()、interrupt()、InterruptedException。串接起
   * 来就是这个意思：当我们在run方法中调用sleep（或其他阻塞线程的方法）时，如果线程阻塞的
   * 时间过长，比如10s，那在这10s内，线程阻塞，run方法不被执行，但是如果在这10s内，stop被
   * 设置成true，表明要终止这个线程，但是，现在线程是阻塞的，它的run方法不能执行，自然也就
   * 不能检查stop，所 以线程不能终止，这个时候，我们就可以用interrupt()方法了：我们在
   * thread.stop = true;语句后调用thread.interrupt()方法， 该方法将在线程阻塞时抛出一个中断
   * 信号，该信号将被catch语句捕获到，一旦捕获到这个信号，线程就提前终结自己的阻塞状态，这
   * 样，它就能够 再次运行run 方法了，然后检查到stop = true，while循环就不会再被执行，在执
   * 行了while后面的清理工作之后，run方法执行完 毕，线程终止。
   *
   */

  /**
   * 注意这个例子是非阻塞的线程，也就是该线程没有调用Object.await，thread.join和thread.sleep上
   */
  public static void main(String[] args) 
    //在main线程sleep的过程中由于t线程中isInterrupted()为false所以不断的输出”Thread is going”。
    // 当调用t线程的interrupt()后t线程中isInterrupted()为true。此时会输出Someone interrupted me.
    // 而且线程并不会因为中断信号而停止运行。因为它只是被修改一个中断信号而已。
    InterruptedThread t = new InterruptedThread();
    t.start();
    System.out.println(Thread.currentThread().isInterrupted());
    try 
      Thread.sleep(3000);
      //只是更改了一个标志位而已，并没有中断线程
      t.interrupt();
     catch (InterruptedException e) 

    

  

例如上述代码，在线程开始执行的时候，线程没有被中断，所以isInterrupted（）返回的是false，但是当main的主线程执行interrupted的时候，中断了该线程，由于该线程处于阻塞状态，所以抛出一个异常，立马清除标志位，还是返回的是false。

再看下面的代码

Thread t1 = new Thread( new Runnable()
    public void run()
        // 若未发生中断，就正常执行任务
        while(!Thread.currentThread.isInterrupted())
            // 正常任务代码……
        

        // 中断的处理代码……
        doSomething();
    
 ).start();

上述代码，在执行过程中，由于刚开始没有被中断返回的是false，所以执行正常任务的代码，当调用interrupted方法后，线程被中断返回的是true，则执行中断的代码逻辑