java中断机制实例讲解
一、导言
线程a对线程b发出建议: 你好，可以停止了哟~
在实际生产环境中，对于阻塞任务，可能存在一些情况导致阻塞任务取消、终止，例如: 计时器到期，i/o 完成，或者另一个线程的动作（释放一个锁，设置一个标志，或者将一个任务放在一个工作队列中)。这种情况下可以使用java的中断机制来进行线程间通信。
java线程中断的实现是基于一个称为中断状态的内部标志位来实现的，其中断的含义更像是建议，一个线程如何响应另一个线程的中断完全取决于程序员: 继续向上抛出、封装后抛出、中断状态复原、忽略等。java库中的许多抛出 interruptedexception 的方法(例如 sleep)都被设计为取消当前操作并在接收到中断时立即返回。
interruptexception异常就像是一个声明，声明抛出该异常的方法都可被中断，比如wait、sleep、join。异常都是由可中断方法自己抛出来的，并不是直接由interrupt()方法直接引起的。一般来说，任何通过抛出一个 interruptedexception 来退出的方法都应该清除中断状态。
二、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后不做处理(“生吞中断”)。
五、参考文章
到此这篇关于java中断机制实例讲解的文章就介绍到这了,更多相关java中断机制内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！