Linux学习笔记--crond任务调度

MVC小系列(十三)【全局异常处理与异常日志】

  返回  

JAVA 线程中断究竟是个啥玩意

2021/8/20 10:47:12 浏览:

个人对中断的理解:

线程中断就是一个信号,当有调用中断方法之后会发送一个中断信号,interrupted()或isInterrupted()的返回值会是true,没有中断信号时interrupted()或isInterrupted()的返回值是false。接收到信号之后,线程是进入执行状态、就绪状态、阻塞状态、还是死亡状态要看你程序怎么写了。

你可以自己写一套判断机制,接收到中断信号之后再判断一下线程目前执行的任务到了什么地步,和线程的属性来决定将线程设置成什么状态。如果你自己不写的话,貌似是有系统默认的判断机制。

大概的写法:

if (Thread.interrupted())
{
    /* 对线程执行任务的进度和线程属性的判断 */
    /* 和判断后对线程状态的设置以及其他反应 */
}

一个线程在未正常结束之前, 被强制终止是很危险的事情. 因为它可能带来完全预料不到的严重后果. 所以你看到Thread.suspend, Thread.stop等方法都被Deprecated了.

那么不能直接把一个线程搞挂掉, 但有时候又有必要让一个线程死掉, 或者让它结束某种等待的状态 该怎么办呢? 优雅的方法就是, 给那个线程一个中断信号, 让它自己决定该怎么办. 比如说, 在某个子线程中为了等待一些特定条件的到来, 你调用了Thread.sleep(10000), 预期线程睡10秒之后自己醒来, 但是如果这个特定条件提前到来的话, 你怎么通知一个在睡觉的线程呢? 又比如说, 主线程通过调用子线程的join方法阻塞自己以等待子线程结束, 但是子线程运行过程中发现自己没办法在短时间内结束, 于是它需要想办法告诉主线程别等我了. 这些情况下, 就需要中断.

中断是通过调用Thread.interrupt()方法来做的. 这个方法通过修改了被调用线程的中断状态来告知那个线程, 说它被中断了. 对于非阻塞中的线程, 只是改变了中断状态, 即Thread.isInterrupted()将返回true; 对于可取消的阻塞状态中的线程, 比如等待在这些函数上的线程, Thread.sleep(), Object.wait(), Thread.join(), 这个线程收到中断信号后, 会抛出InterruptedException, 同时会把中断状态置回为false.

下面的程序会演示对非阻塞中的线程中断:

public class Thread3 extends Thread{  
    public void run(){  
        while(true){  
            if(Thread.interrupted()){  
                System.out.println("Someone interrupted me.");  
            }  
            else{  
                System.out.println("Going...");  
            }  
            long now = System.currentTimeMillis();  
            while(System.currentTimeMillis()-now<1000){  
                // 为了避免Thread.sleep()而需要捕获InterruptedException而带来的理解上的困惑,  
                // 此处用这种方法空转1秒  
            }  
        }  
    }  
      
    public static void main(String[] args) throws InterruptedException {  
        Thread3 t = new Thread3();  
        t.start();  
        Thread.sleep(3000);  
        t.interrupt();  
    }  
} 

中断状态可以通过 Thread.isInterrupted()来读取,并且可以通过一个名为 Thread.interrupted()的静态方法读取和清除状态(即调用该方法结束之后, 中断状态会变成false)。 

由于处于阻塞状态的线程 被中断后抛出exception并置回中断状态, 有时候是不利的, 因为这个中断状态可能会作为别的线程的判断条件, 所以稳妥的办法是在处理exception的地方把状态复位:

当代码调用中须要抛出一个InterruptedException, 你可以选择把中断状态复位, 也可以选择向外抛出InterruptedException, 由外层的调用者来决定.

不是所有的阻塞方法收到中断后都可以取消阻塞状态, 输入和输出流类会阻塞等待 I/O 完成,但是它们不抛出 InterruptedException,而且在被中断的情况下也不会退出阻塞状态.

尝试获取一个内部锁的操作(进入一个 synchronized 块)是不能被中断的,但是 ReentrantLock 支持可中断的获取模式即 tryLock(long time, TimeUnit unit)。

联系我们

如果您对我们的服务有兴趣,请及时和我们联系!

服务热线:18288888888
座机:18288888888
传真:
邮箱:888888@qq.com
地址:郑州市文化路红专路93号