Java编程的逻辑 -- 并发章 -- 线程的中断
线程中断
在Java中,停止一个线程的主要机制是中断,中断并不是强迫终止一个线程,它是一种协作机制,是给线程传递一个取消信号,但是由线程来决定如何以及何时退出。本节我们主要就是来理解Java的中断机制
线程中断的三个方法:
public boolean isInterrupted()
public void interrupt()
public static boolean interrupted()
- isInterrupted返回当前线程是否被中断。true/false
- interrupted不但具有isInterrupted的共同,同时每次调用还会清空该中断标志位。即某一个线程被中断了第一次调用为true第二次一般就为false。需要注意的是该方法是静态方法,中断的是正在执行的线程。 而其他两个方法则是中断this对象指定的线程。
- interrupt中断对应线程。
线程不同状态对中断的反应
interrupt ()对线程的影响与线程的状态和在进行的IO操作有关。我们主要考虑线程的状态,I/O操作的影响和具I/O以及操作系统有关,我们就不讨论了。
线程状态有:
- RUNNABLE:线程在运行或具备运行条件只是在等待操作系统调度。
- WAITING/TIMED_WAITING:线程在等待某个条件或超时。
- BLOCKED:线程在等待锁,试图进入同步块。
- NEWATERMINATED:线程还未启动或已结束。
1.RUNNABLE
如果线程在运行中,且没行执行I/O操作,interrupt()只是会设置线程的中断标忐位,没行任何其他作用。线程应该在运行过程中合适的位置检查中断标志位,比如,如果主体代码是一个循环,可以在循环开始处进行检查,如下所示:
public class InterruptRunnableDemo extends Thread {
@Override
public void run() {
while(!Thread.currentThread().isInterrupted()) {
//…单词循环代码
}
System.out.println("done ");
}
//其他代码
}
2.WAITING/TIMED_WAITING
线程调用join/wait/sleep方法会进入WAITING
或TIMED_WAITING
状态。在对线程对象调用interrupt()后,当线程处于中断状态时,如果再由wait、sleep以及jion三个方法引起的阻塞,那么JVM会将线程的中断标志重新设置为false,并抛出一个InterruptedException异常。比如,执行如下代码:
Thread t = new Thread (){
@Override
public void run() {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
System.out.println(isInterrupted());
}
}
};
t.start();
try {
Thread.sleep(100);// 确保该线程 睡开了
} catch (InterruptedException e) {
}
t.interrupt();
程序的输出为false。
IntemiptedException是一个受检异常,线程必须进行处理。我们在异常处理中介绍过,处理异常的基本思路是:如果知道怎么处理,就进行处理,如果不知道,就应该向上传递,通常情况下不应该捕获异常然后忽略。
捕获到InterruptedException,通常表示希望结朿该线程,线程大致有两种处理方式:
- 向上传递该异常,这使得该方法也变成一个可中断的方法(相当于封装了一下),需要调用者记性处理。
- 有些情况,不能向上传递异常,比如 Thread的run方法,它的声明是固定的,不能 ++抛出++ 任何受检异应该捕获异常,** 进行合适的清理操作,清理后,一般应该调用Thread的interrupt方法设置中断标志位,使得其他代码有办法知道它发生了中断。
第一种示例代码:
对Thread类的sleep方法进行了封装而不是直接在run方法中调用就可以保证interruptedException可以在run方法调用该interruptibleMethod方法时被抛出了。
public void interruptibleMethod() throws InterruptedException{
//…这里可以是wait, join 或者 sleep 方法
Thread.sleep(1000);
}
第二种示例代码:
public class InterruptWaitingDemo extends Thread {
@Override
public void run() {
while(!Thread.currentThread().isInterrupted()) {
try {
//模拟任务代码
Thread.sleep(2000);
} catch(InterruptedException e) {
//…清理操作
//重新设置中断标志位 方便其他代码知道该线程发生了中断
Thread.currentThread().interrupt();
}
}
System.out.println(isInterrupted());
}
//其他代码
}
3.BLOCKED
当线程处于BLOCKED状态等待CPU调度时。调用线程的interrupt()方法并不能使一个正在等待的线程真正中断。
4.NEW/TERMINATE
如果线程尚未启动(NEW),或者已经结束(TERMINATE),则调用interrupt()方法对其没有任何效果。并且线程的中断标志位也不会被设置。
总结
本节主要讲的是如何取消以及关闭线程,主要采用的是中断技术。他是一种协作机制,并不会强制中断线程。并且介绍了线程在不同状态下对于中断操作的反应。