java 中断api

interrupt()

interrupt()方法本质上就是通过调用java.lang.Thread#interrupt0设置中断flag为true，如下代码演示了该方法的使用: 另启一个线程中断了当前线程。

@Test
public void interruptSt() {
 Thread mainThread = Thread.currentThread();
 new Thread(/*将当前线程中断*/mainThread::interrupt).start();
 try {
 //public static native void sleep(long millis) throws InterruptedException;
 Thread.sleep(1_000);
 } catch (InterruptedException e) {
 System.out.println("main 线程被中断了");
 }
 /*
 * 输出: main 线程被中断了
 */
}

interrupted()和isInterrupted()

public boolean isInterrupted() {
 // 设置this线程的中断flag，不会重置中断flag为true
 return isInterrupted(false);
}
public /*静态方法*/static boolean interrupted() {
 // 设置当前线程的中断flag,重置中断flag为true
 return currentThread().isInterrupted(true);
}

使用示例

@Test
public void test_Flag() {
 Thread currentThread = Thread.currentThread();
 currentThread.interrupt();
 System.out.println("当前线程状态 =" + currentThread.isInterrupted());
 System.out.println("当前线程状态 =" + Thread.interrupted());
 System.out.println("当前线程状态 =" + Thread.interrupted());
 /* 输出
 当前线程状态 =true
 当前线程状态 =true
 当前线程状态 =false*/
}

三、如何响应中断?

调用一个可中断的阻塞方法时需要处理受检异常InterruptException，一般来说最容易的方式就是继续抛出InterruptException ，让调用方决定对中断事件作出什么应对。但是对于一些不能在方法头直接添加异常声明的，可以catch出后再进行一些操作，例如使用Runnable时:

一般来说当catch到中断时，应该对中断状态进行还原: 调用Thread.currentThread().interrupt();，除非明确自己的操作不会丢失线程中断的证据，从而剥夺了上层栈的代码处理中断的机会。

总结

对目标线程调用interrupt()方法可以请求中断一个线程，目标线程通过检测isInterrupted()标志获取自身是否已中断。如果目标线程处于阻塞状态，该线程会捕获到InterruptedException。一般来说不要catchInterruptException后不做处理(“生吞中断”)。