因为在并发中经常会用到Thread的中断机制，这个东西也不是那么容易搞明白，所以我就写一篇文章说明一下昂。
Thread中有一个方法：
public voidinterrupt() {
if(this!= Thread.currentThread())
checkAccess();
synchronized(blockerLock) {
Interruptible b =blocker;
if(b !=null) {
interrupt0(); // 设置interrupt标志
b.interrupt(this);
return;
}
}
interrupt0();
}
这个方法就是所谓的中断方法，它做了什么呢，首先判断是否被修改的线程实例就是当前线程，如果不是，会去检查当前线程是否有修改该线程的权限（具体怎么检查可以另外再写一篇了~心情好的时候就会写一篇~）
检查完有权限后，要拿到blockerLock这个锁（或者称为监视器monitor），之后轮到这个字段登场：
private volatile Interruptible blocker;
根据注释：
/* The object in which this thread is blocked in an interruptible I/O
* operation, if any. The blocker's interrupt method should be invoked
* after setting this thread's interrupt status.
*/
我翻译一下：这个对象用来干嘛呢，就是在当前线程在可中断的IO操作中处于阻塞状态时，在设置了对象的interrupt状态后，必须得调用这个对象的interrupt方法。
嗯，读完我依然不是很懂，那这个对象的interrupt方法到底做了什么，我根本没找到它的实现方式是什么，然后翻呀翻，才发现JAVA8已经不用这玩意了，确切说1.6以后就不用了，那意味着神马，就是在java8里，这个b，它一定是个null，那么其实就是执行interrupt0()这个native方法，也就是去设置了一下interrupt这个标志。
然后调用另一个方法：
public static booleaninterrupted() {
returncurrentThread().isInterrupted(true);
}
这个方法会去获取当前线程的interrupt状态，并清除当前的interrupt状态(设为false)，因为下面这个方法：
private native boolean isInterrupted(boolean ClearInterrupted);
它接收一个boolean参数，如果为true表示清除当前的的interrupt状态，即设置interrupt标志位false，如果参数为false，则表示保持当前interrupt标志不变，就该是啥是啥。
所以如果你是为了查询interrupt标志而不希望重置它的状态的话，需要调用另一个方法：
public booleanisInterrupted() {
returnisInterrupted(false);
}
这个方法就会去查询当前interrupt标志状态而不会重置它。
讲了那么久设置这个interrupt标志，那么这个标志到底有什么用，到底用来干什么？
嗯。。因为不少方法会去判断这个标志，通过这个标志来进行一些操作，比如哈，我们thread里的sleep方法：
public static native void sleep(long millis) throws InterruptedException;
这是一个本地方法，但我们可以看说明：
if any thread has interrupted the current thread. The<i>interrupted status</i>of the current thread is cleared when this exception is thrown.
翻译：就是只要任何线程中断了当前线程（当前线程的interrupt标志为true），那么sleep就不会正常执行而是直接抛InterruptedException异常。
再比如Object里的wait()方法：
public final native void wait(long timeout) throws InterruptedException;
也是本地方法，它也会去检测是否interrupt标志为true，如果是则直接抛InterruptedException异常。
等等等等还有一些。
很多native方法都通过这种方式来检测中断然后就抛异常，并且当抛出InterruptedException异常的时候，当前线程的interrupt标志就会被重置, 意思就是，当抛了异常后，当前线程的interrupt标志就变为了false。
记住中断后（interrupt()方法执行后），线程并不会停止运行，因为这个方法仅仅只是设置了interrupt标志而已，所以，在你需要真正中断线程的时候，你可以通过判断这个interrupt标志位来决定你程序该怎么走，但是不幸的是，很多库里面是有捕获InterruptedException这个异常的操作的，那么但凡这些库里面有执行sleep或者wait或者任何会去检查这个标志并抛InterruptedException的情况，那这个标志在某些情况下就会莫名其妙就被重置了，你很难发现它被中断了。
执行一下下面的代码试试：
public static voidmain(String[] args) {
Thread thread = Thread.currentThread();
thread.interrupt();
System.out.print(thread.isInterrupted());
try{
thread.sleep(1000);
}catch(InterruptedException e) {
}
System.out.print(thread.isInterrupted());
}
所以其实这个机制还是有那么点问题的哈，所以通常的做法是，如果你的代码里有catch (InterruptedException e)这个异常捕获的行为，并且这个中断和你的代码没有关系（你这部分代码并不处理这个中断信号相关的事情），那么请调用一下Thread.currentThread().interrupt()将中断设置成true（因为会进到这个异常捕获里面就代表了中断信号为true）。这样后面依赖这个中断信号的程序才能正常运行。
好的说完啦，推荐一下大家去看看AQS的源码怎么处理这个中断信号滴~
网友评论