Java 中的线程中断是一种线程间的协作模式,通过设置线程的中断标志并不能直接终止该线程的执行,而是被中断的线程根据中断状态自行处理。
● void interrupt()方法 :中断线程,例如,当线程 A 运行时,线程 B 可以调用线程 A 的 interrupt()方法来设置线程 A 的中断标志为 true 并立即返回。设置标志仅仅是设置标志,线程 A 实际并没有被中断,它会继续往下执行。如果线程 A 因为调用了 wait 系列函数、join 方法或者 sleep 方法而被阻塞挂起,这时候若线程 B 调用线程 A 的 interrupt()方法,线程 A 会在调用这些方法的地方抛出 InterruptedException 异常而返回。
● boolean isInterrupted()方法:检测当前线程是否被中断,如果是返回 true,否则返回 false。
public boolean isInterrupted() {
//传递 false,说明不清除中断标志
return isInterrupted(false);
}
● boolean interrupted()方法:检测当前线程是否被中断,如果是返回 true,否则返回 false。与 isInterrupted 不同的是,该方法如果发现当前线程被中断,则会清除中断标志,并且该方法是 static 方法,可以通过 Thread 类直接调用。另外从下面的代码可以知道,在 interrupted()内部是获取当前调用线程的中断标志而不是调用 interrupted()方法的实例对象的中断标志。
public static boolean interrupted() {
//清除中断标志
return currentThread().isInterrupted(true);
}
下面看一个线程使用 Interrupted 优雅退出的经典例子,代码如下。
public void run(){
try{
....
//线程退出条件
while(! Thread.currentThread().isInterrupted()&& more work to do){
// do more work;
}
}catch(InterruptedException e){
// thread was interrupted during sleep or wait
}
finally{
// cleanup, if required
}
}
下面看一个根据中断标志判断线程是否终止的例子。
public static void main(String[] args) throws InterruptedException {
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
//如果当前线程被中断则退出循环
while (! Thread.currentThread().isInterrupted())
System.out.println(Thread.currentThread() + 「 hello」);
}
});
//启动子线程
thread.start();
//主线程休眠 1s,以便中断前让子线程输出
Thread.sleep(1000);
//中断子线程
System.out.println(「main thread interrupt thread」);
thread.interrupt();
//等待子线程执行完毕
thread.join();
System.out.println(「main is over」);
}
输出结果如下.
在如上代码中,子线程 thread 通过检查当前线程中断标志来控制是否退出循环,主线程在休眠 1s 后调用 thread 的 interrupt()方法设置了中断标志,所以线程 thread 退出了循环。
下面再来看一种情况。当线程为了等待一些特定条件的到来时,一般会调用 sleep 函数、wait 系列函数或者 join()函数来阻塞挂起当前线程。比如一个线程调用了 Thread. sleep(3000),那么调用线程会被阻塞,直到 3s 后才会从阻塞状态变为激活状态。但是有可能在 3s 内条件已被满足,如果一直等到 3s 后再返回有点浪费时间,这时候可以调用该线程的 interrupt()方法,强制 sleep 方法抛出 InterruptedException 异常而返回,线程恢复到激活状态。下面看一个例子。
public static void main(String[] args) throws InterruptedException {
Thread threadOne = new Thread(new Runnable() {
public void run() {
try {
System.out.println(「threadOne begin sleep for 2000 seconds」);
Thread.sleep(2000000);
System.out.println(「threadOne awaking」);
} catch (InterruptedException e) {
System.out.println(「threadOne is interrupted while sleeping」);
return;
}
System.out.println(「threadOne-leaving normally」);
}
});
//启动线程
threadOne.start();
//确保子线程进入休眠状态
Thread.sleep(1000);
//打断子线程的休眠,让子线程从 sleep 函数返回
threadOne.interrupt();
//等待子线程执行完毕
threadOne.join();
System.out.println(「main thread is over」);
}
输出结果如下。
在如上代码中,threadOne 线程休眠了 2000s,在正常情况下该线程需要等到 2000s 后才会被唤醒,但是本例通过调用 threadOne.interrupt()方法打断了该线程的休眠,该线程会在调用 sleep 方法处抛出 InterruptedException 异常后返回。
下面再通过一个例子来了解 interrupted()与 isInterrupted()方法的不同之处。
public static void main(String[] args) throws InterruptedException {
Thread threadOne = new Thread(new Runnable() {
public void run() {
for(; ; ){
}
}
});
//启动线程
threadOne.start();
//设置中断标志
threadOne.interrupt();
//获取中断标志
System.out.println(「isInterrupted:」 + threadOne.isInterrupted());
//获取中断标志并重置
System.out.println(「isInterrupted:」 + threadOne.interrupted());
//获取中断标志并重置
System.out.println(「isInterrupted:」 + Thread.interrupted());
//获取中断标志
System.out.println(「isInterrupted:」 + threadOne.isInterrupted());
threadOne.join();
System.out.println("main thread is over");
}
输出结果如下。
第一行输出 true 这个大家应该都可以想到,但是下面三行为何是 false、false、true 呢,不应该是 true、false、false 吗?如果你有这个疑问,则说明你对这两个函数的区别还是不太清楚。上面我们介绍了在 interrupted()方法内部是获取当前线程的中断状态,这里虽然调用了 threadOne 的 interrupted()方法,但是获取的是主线程的中断标志,因为主线程是当前线程。threadOne.interrupted()和 Thread.interrupted()方法的作用是一样的,目的都是获取当前线程的中断标志。修改上面的例子为如下。
public static void main(String[] args) throws InterruptedException {
Thread threadOne = new Thread(new Runnable() {
public void run() {
//中断标志为 true 时会退出循环,并且清除中断标志
while (! Thread.currentThread().interrupted()) {
}
System.out.println(「threadOne isInterrupted:」 + Thread.currentThread().
isInterrupted());
}
});
// 启动线程
threadOne.start();
// 设置中断标志
threadOne.interrupt();
threadOne.join();
System.out.println(「main thread is over」);
}
输出结果如下。
由输出结果可知,调用 interrupted()方法后中断标志被清除了。