Thread中断机制涉及的方法或者属性有三个：
public boolean isInterrupted();
public static boolean interrupted();
public void interrupt();
isInterrupted
首先看第一个，它很简单，用来判断这个线程是否被中断，true标识中断，此方法不影响线程的状态。
interrupted
此方法和isInterrupted的区别在于,它会清除线程的中断状态，当一个线程中断之后，连续调用两次该方法，第一次返回结果为true，第二次返回结果为false。
interrupt
先看API注释，我大概提取了几个意思，下面就所理解的做说明（建议去看原文）：
- 中断调用线程，并不中断流程，只是修改中断状态为true，流程由开发者控制。
public class MainTest {
public static void main(String[] args) {
TestThread thread = new TestThread();
thread.start();
try {
Thread.sleep(1);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
thread.interrupt();
System.out.println("中断之后:" +thread.isInterrupted() );
}
}
class TestThread extends Thread{
@Override
public void run() {
// TODO Auto-generated method stub
super.run();
for (int j = 0; j < 300; j++) {
System.out.println("输出:" + j + "--中断状态:" +this.isInterrupted() );
}
System.out.println("线程执行完成");
}
}
运行代码，我们可以看到，状态值已经改变，但中断之后的操作，开发者自己设计。
输出:2--中断状态:false
输出:3--中断状态:false
输出:4--中断状态:true
中断之后:true
输出:5--中断状态:true
输出:6--中断状态:true
- 调用者线程如果被如
wait(),join(),sleep()方法阻塞时，将抛出InterruptedException异常，并且重置中断状态。
public class MainTest {
public static void main(String[] args) {
TestThread thread = new TestThread();
thread.start();
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
thread.interrupt();
System.out.println("中断之后:" +thread.isInterrupted() );
}
}
class TestThread extends Thread{
@Override
public void run() {
// TODO Auto-generated method stub
super.run();
for (int j = 0; j < 20; j++) {
System.out.println("输出:" + j + "--中断状态:" +this.isInterrupted() );
try {
Thread.sleep(200);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
System.out.println("线程执行完成");
}
}
输出:4--中断状态:false
输出:5--中断状态:false
中断之后:true
java.lang.InterruptedException: sleep interrupted
输出:6--中断状态:false
at java.lang.Thread.sleep(Native Method)
at com.cs.多线程.中断.TestThread.run(MainTest.java:35)
输出:7--中断状态:false
输出:8--中断状态:false
这个时候可以看到，调用中断方法之后，中断状态变成true，然后由于sleep()抛出InterruptedException异常，状态被重置所以马上恢复为false。捕获异常可以根据需要进行处理，一般是上抛或者其他逻辑，此处需要注意，System.out.println("中断之后:" +thread.isInterrupted() );该处打印并不一定结果为true，这取决于主，子线程的执行速度以及状态修改的时机。
- 线程中出现
I/O阻塞，此时在线程中被等待连接的状态中阻塞，进行中断并不能退出线程，此时需要关闭socket在IOException异常捕获时退出。
public class SocketThread extends Thread {
private ServerSocket socket;
public static void main( String args[] ) throws Exception {
SocketThread thread = new SocketThread();
System.out.println("启动线程" );
thread.start();
//这里假设3秒没有客户端连接就需要结束线程
Thread.sleep(3000);
System.out.println("中断线程" );
thread.interrupt();
System.out.println("关闭socket通道");
thread.socket.close();
}
@Override
public void run() {
try {
socket = new ServerSocket(12345);
} catch ( IOException e ) {
return;
}
while (! Thread.currentThread().isInterrupted()) {
try {
System.out.println("等待客户端连接...");
Socket sock = socket.accept();
} catch ( IOException e ) {
System.out.println("I/O异常");
break;
}
}
System.out.println("线程执行结束" );
}
}
- 线程中出现
java.nio.channels.Selector阻塞，待续。 - 中断非活动线程没有效果
- 当前线程不能修改该线程将抛出
SecurityException异常
参考:
https://blog.csdn.net/meiliangdeng1990/article/details/80559012
https://www.cnblogs.com/jenkov/p/juc_interrupt.html
https://www.ibm.com/developerworks/cn/java/j-jtp05236.html
