Java 并发:线程中断-interrupt

2023-06-02,,

一直以为执行了interrupt方法就可以让线程结束,并抛出InterruptedException. 今天看了Java并发编程实战的第七章发现并不是这么回事,在这章的开头就提到

要使任务和线程能安全、快速、可靠地停止下来,并不是一件容易的事。Java没有提供任何机制来安全地终止线程。但它提供了(Interruption),这是一种协作机制,能够使一个线程终止另一个线程的当前工作

如上提到的是协作,而不是强制。因为如果需要被中断的线程任务实现没有准守这样的协作约定,那么其他线程就没有办法通过interrupt去中断它。比如下面的foreverThread就没有对interrupt设置的boolean变量进行检测。

        Thread foreverThread = new Thread(new Runnable() {
@Override
public void run() {
int t = ;
for (int i = ; i < ; i++) {
i--;
if (t++ % == ) {
System.out.println(".");
}
}
}
});
foreverThread.start();
foreverThread.interrupt();

如书中所述,每个线程都有一个boolean类型的中断状态,我们可以通过调用线程的interrupt方法来设置这个值为true,并通过isInterrupted方法来检测这个值是否被置为true。这样当一个线程(比如主线程)通过调用另外一个(比如任务)线程interrupt方法,然后这个任务线程内有检测该boolean值是否置位的逻辑,如果为true这中止当前的工作,然后按照库方法那样抛出一个InterruptException来提示当前任务执行被中断了。因为interrupt设置这个boolean变量是线程体相关的,一次设置后它会一直存在于线程体,这样如果不把它重新置为false,那么执行后续其他会检测这个变量的操作就会立即退出抛出InterruptException。出于这样的原因,当检测到这个boolean标记被设为true后,在要抛出InterruptException之前,还要通过调用Thread.interrupted()方法来重置这个boolean标记(即设为false)以免影响后续的操作(这也表示执行这个动作的这部分代码处理了这次中断请求,至于怎么处理,一般就是上文所说的抛出InterruptException)。

阻塞库方法,例如Thread.sleep和Object.wait等,都会检测线程何时中断,并且在发现中断时提前返回。它们在响应中断时执行的操作包括:清除中断状态,抛出InterruptException,表示阻塞操作由于中断而提前结束。

线程实例的interrupt方法用于设置boolean标记,静态的Thread.interrupted方法用于清除boolean标记(即置为false,同时返回以前的boolean值)下面是一个实例:

        Thread iThread = Thread.currentThread();

        iThread.interrupt();

        System.out.println(iThread.isInterrupted());

        System.out.println(Thread.interrupted());

        System.out.println(iThread.isInterrupted());

输出如下:

true
true
false

使用静态的interrupted时应该小心,因为它会清除当前线程的中断状态。如果在调用interrupted时返回了true,那么除非你想屏蔽这个中断,否则必须对它进行处理——可以抛出InterruptedException,或者通过再次调用interrupt来恢复中断

如果我们在检测到interrupt中断后,抛出异常却不调用interrupted清除标记,那么会影响到以后的其他可中断调用:

        BlockingQueue<Integer> queue = new LinkedBlockingQueue<Integer>();

        Thread iThread = Thread.currentThread();

        iThread.interrupt();

        System.out.println(iThread.isInterrupted());

        try {
queue.take();
} catch (InterruptedException e) {
System.out.println("thread is interrupted, isInterrupted:" + iThread.isInterrupted());
}

输出:

true
thread is interrupted, isInterrupted:false

运行以上代码片段,程序会立即结束而不会再queue.take()上等待。在库函数抛出InterruptException后,通过isInterrupted检测可以发现中断boolean标记已经被清除(置为false)

Java 并发:线程中断-interrupt的相关教程结束。

《Java 并发:线程中断-interrupt.doc》

下载本文的Word格式文档,以方便收藏与打印。