建设厅网站生成案卷生成不了,本地app制作公司地址,博客群wordpress,好做网站Thread 类虽提供了一个 stop() 方法#xff08;已经被废弃#xff09;#xff0c;但由于 stop() 方法强制终止一个正在执行的线程#xff0c;可能会造成数据不一致的问题#xff0c;所以在生产环境中最好不要使用。
场景#xff1a;
由于一些操作需要轮询处理#xff…Thread 类虽提供了一个 stop() 方法已经被废弃但由于 stop() 方法强制终止一个正在执行的线程可能会造成数据不一致的问题所以在生产环境中最好不要使用。
场景
由于一些操作需要轮询处理且需要保证数据的一致性和完整性。在发布项目时需要安全的结束正在运行的线程才能启动服务。 根据以上场景记录一下安全终止线程的方式 用 volatile 标记停止线程
使用 volatile 作为标记位的核心就是他的可见性特性线程的中根据这个标记判断是否退出通常这种情况一般是在 run 方法中循环执行的。
项目启动时启动要做轮询的线程
Component
public class ServerBootstrapListener implements ApplicationListenerApplicationStartedEvent {Overridepublic void onApplicationEvent(ApplicationStartedEvent applicationStartedEvent) {System.out.println(ServerBootstrapListener.......);DemoRunnable demoRunnable new DemoRunnable();new Thread(demoRunnable, DemoRunnable).start();}} 线程执行逻辑
public class DemeRunnable implements Runnable {// 退出标识private static volatile boolean isClose true;Overridepublic void run() {while (isClose) {try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}log.info(线程执行中....);}log.info(isClose{}线程结束., isClose);}public static void isClose() {isClose false;}
}
通过访问当前地址安全的结束线程
GetMapping(value /close)
void close() {DemoRunnable.isClose();
}
在一些特殊场景使用 volatile 时是有一个的风险的所以建议使用下边使用关于【volatile 修饰标记位不适用的场景】请自行查找。 使用 interrupt 终止线程
Thread.java类中提供了两种方法
this.interrupted(): 测试当前线程是否已经中断this.isInterrupted(): 测试线程是否已经中断interrupt() 方法本身是不会终止线程的需要一个间接接实现的方式终止线程。
为什么说是简接实现呢因为线程执行 interrupt() 方法并不会直接终止线程。 简单分析一下 interrupt() 实现安全终止线程的过程
首先当执行线程的 interrupt() 方法后就会给该线程打上一个中断的标识属性有点类似 volatitle 变量的可见性玩法。通过这样的可见性变量我们就可以设置某种状态当满足该状态时就结束线程。
接下来根据 isInterrupted() 方法获取到中断标识属性的状态值就可以判断是否束该线程。 项目启动时启动要做轮询的线程
Component
public class ServerBootstrapListener implements ApplicationListenerApplicationStartedEvent {Overridepublic void onApplicationEvent(ApplicationStartedEvent applicationStartedEvent) {System.out.println(ServerBootstrapListener.......);DemoRunnable two new DemoRunnable();Thread thread new Thread(two, DemoRunnable);thread.start();two.setCurrentThread(thread);}}线程执行逻辑
Slf4j
public class DemoRunnable implements Runnable {private static Thread currentThread;SneakyThrowsOverridepublic void run() {while (true) {if (Thread.currentThread().isInterrupted()) {System.out.println(线程已经终止循环不再执行);return;}try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}log.info(线程执行中....);}}public static Thread getCurrentThread() {return currentThread;}public void setCurrentThread(Thread currentThread) {DemoRunnable.currentThread currentThread;}
} 通过访问当前地址安全的结束线程
GetMapping(value /close)
void close() {Thread currentThread DemoRunnable.getCurrentThread();currentThread.interrupt();
} 总结
通过上面的介绍线程终止的两种方式一种是 interrupt 一种是 volatile 两种类似的地方都是通过标记来实现的 interrupt 是中断信号传递基于系统层次的不受阻塞影响而对于 volatile 是利用其可见性而顶一个标记位标量但是当出现阻塞等时无法进行及时通知。 在我们平时的开发中我们视情况而定在一般情况下都是可以使用 volatile 但是这需要我们精确的掌握其中的场景。
