Java中如何实现线程的超时中断
转载自 Java中如何实现线程的超时中断
背景
之前在实现熔断降级组件的时候,需要实现接口请求的超时中断。意思是,业务在使用熔断降级功能时,在平台上设置了一个超时时间,如果请求进入熔断器开始计时,接口在超时时间内没有响应,则需要提早中断该请求并返回。
比如正常下游接口的超时时间为800ms,但是因为自身业务的特殊需求,最多只能等200ms,如果指定之内没有数据返回,则返回降级数据。这里处理请求的线程可以看成是tomcat线程池中的一个线程,如果通过线程池返回的Future,可以很轻松的实现超时中断返回,但是当前情况下,并不能拿到Futrue,又不想额外引入一个线程池,所以需要另外一种实现思路。
思路
中断一个线程的思路有哪些? 除了已经废弃的Thread.stop, Thread.suspend, Thread.resume 方法,剩下的貌似只有一种方案了,就是调用当前线程的 interrupt()
,但是这个方法的作用并不是中断线程,而是设置一个标识,通知该线程可以被中断了,到底是继续执行,还是中断返回,由线程本身自己决定。
具体来说,当对一个线程调用了 interrupt()
之后,如果该线程处于被阻塞状态(比如执行了wait、sleep或join等方法),那么会立即退出阻塞状态,并抛出一个 InterruptedException
异常,在代码中catch这个异常进行后续处理。如果线程一直处于运行状态,那么只会把该线程的中断标志设置为 true,仅此而已,所以 interrupt()
并不能真正的中断线程,不过在rpc调用的场景中,请求线程一般都处于阻塞状态,等待数据返回,这时 interrupt()
方法是可以派上用场的。
那么,要实现指定超时时间内中断请求线程,还有最后一个问题需要解决:什么时候,由谁去执行 interrupt()
方法?
必然这个方法只能由其它线程来执行了(自己都阻塞了,执行个鬼),而且是在请求进入熔断器时,并在超时时间之后执行,有点绕,比如超时时间是200ms,那么请求进入熔断器之后,再过200ms,就执行 interrupt()
,但是在200ms之内有数据返回,那么就不执行 interrupt()
了。
实现
需求已经很明确了,相当于延迟执行一个task,其内部逻辑就是执行请求线程的 interrupt()
,当然还有其它的逻辑。
Runnable task = new Runnable() {@Overridepublic void run() {try {thread.interrupt();// 取消定时器任务f.cancel();} catch (Exception e) {logger.error("Failed while ticking TimerListener", e);}}
};
Doug Lea大神提供的 ScheduledThreadPoolExecutor
可以很好的满足这个需求,通过 scheduleAtFixedRate
方法可以很方便的实现在延迟指定时间之后执行提交的任务。
ScheduledFuture<?> f = executor.scheduleAtFixedRate(task, timeout, timeout, TimeUnit.MILLISECONDS);
在请求进入熔断器时,顺便提交一个任务到线程池中等待执行,如果接口在超时时间内没有返回,那么该任务会被触发,并执行请求线程的 interrupt
方法,这样就实现了请求线程的中断(因为这时请求线程正在被阻塞,等待数据返回),另外需要清空定时任务,不然这个任务会一直执行。
如果接口正常返回了,也要记得清空定时任务,并且在请求退出熔断器的时候,记得恢复请求线程的中断标识,如何恢复?在请求线程中执行下面代码即可。
Thread.interrupted();// 内部逻辑
public static boolean interrupted() {return currentThread().isInterrupted(true);
}// 参数为true,可以清除中断标识
private native boolean isInterrupted(boolean ClearInterrupted);
执行当前线程(即请求线程)的isInterrupted方法。
使用这种方式实现请求的超时中断,在QPS很高的情况下,会有额外的性能损失,因为每次请求都要提交一个任务到线程池中等待执行。
Java中如何实现线程的超时中断相关推荐
- Java并发编程—如何实现线程的超时中断
原文作者:大老二在不在 原文地址:Java中如何实现线程的超时中断 目录 背景 思路 实现 背景 之前在实现熔断降级组件时,需要实现一个接口的超时中断,意思是,业务在使用熔断降级功能时,在平台上设置了 ...
- 什么是Java中的守护程序线程?
谁能告诉我Java中有哪些守护程序线程? #1楼 守护程序线程就像其他与守护程序线程在同一进程中运行的线程或对象的服务提供者一样. 守护程序线程用于后台支持任务,仅在执行正常线程时才需要. 如果正常线 ...
- java中的后台线程、前台线程、守护线程区别
java中的后台线程.前台线程.守护线程区别 区别和联系 区别 联系 区别和联系 区别 后台线程和守护线程是一样的. 后台线程不会阻止进程的终止,而前台线程会, 可以在任何时候将前台线程修改为后台线程 ...
- Java中枚举的线程安全性及序列化问题
转载自 Java中枚举的线程安全性及序列化问题 Java SE5提供了一种新的类型-Java的枚举类型,关键字enum可以将一组具名的值的有限集合创建为一种新的类型,而这些具名的值可以作为常规的程序 ...
- Java中的守护程序线程
Daemon thread in java can be useful to run some tasks in background. When we create a thread in java ...
- java中等待所有线程都执行结束
使用CountDownLatch,这其实是最优雅的写法了,每个线程完成后都去将计数器减一,最后完成时再来唤醒 @Test public void testThreadSync3() { final V ...
- 【java】Java 中的 Exchanger 线程同步使用方法 线程之间交换数据
1.概述 转载:https://www.pdai.tech/md/java/thread/java-thread-x-juc-tool-exchanger.html 视频参考:https://www. ...
- java中我爱你_Java线程学习(转)
编写具有多线程能力的程序经常会用到的方法有: run(),start(),wait(),notify(),notifyAll(),sleep(),yield(),join() 还有一个重要的关键字:s ...
- java中四种线程池的区别
本文按: 一. 线程池的使用 二. 几种线程池的区别 三. 如何合理配置线程池 一.线程池的使用 在Java中,通常使用Executors 获取线程池.常用的线程池有以下几种: (1)CachedTh ...
最新文章
- 几行代码实现老照片上色复原!
- Matplotlib的介绍及简单操作
- Source引擎的远程代码执行漏洞,可能影响千万游戏玩家
- Spring Boot 2.x基础教程:Spring Data JPA的多数据源配置
- Python3实现简单可学习的手写体识别
- 各种快速幂(qaq)
- Windows下svn服务器安装
- Python中的常用模块
- (代码篇)从基础文件IO说起虚拟内存,内存文件映射,零拷贝
- Filebeat 将多个日志输出到不同的 Kafka Topic
- .net html第一张图片,基于Asp.net C#实现HTML转图片(网页快照)
- Markdown 写作类软件 MWeb 和 Ulysses谁更好
- mac 安装 JDK
- speedoffice(表格)怎么插入文本框?
- 为什么程序员工资这么高?
- 小米手机-解BL锁+开ROOT权限
- 机器学习在地球物理(地震)中的发展历程_1
- 【情人节警报】看我如何智斗陌陌情爱骗子
- 《罗曼蒂克消亡史》影评
- 四种基础博弈 巴什博奕+威佐夫博奕+斐波那契博弈+K倍博弈
热门文章
- win10新建管理员账户_【经验篇001】Win10专业版如何开启超级管理员账户
- [RabbitMQ]MQ 的分类
- [Java网络编程基础]UDP发送和接收数据
- c语言case怎么输入字母,如何使用switch case语句将字母转换为数字
- 无盘服务器为什么重启还原,无盘站反复重启怎么办
- Java基础知识——Sting、StringBuild、StringBuffer的区别
- HDU 6755 Fibonacci Sum(二次剩余 + 二项式展开)
- P3435 [POI2006]OKR-Periods of Words kmp + fail指针
- 2018 ACM-ICPC World Finals Problem D.Gem Island
- F.孤独(牛客小白月赛39)