Java中实现线程的超时中断方法实例
背景
之前在实现熔断降级组件时，需要实现一个接口的超时中断，意思是，业务在使用熔断降级功能时，在平台上设置了一个超时时间，如果在请求进入熔断器开始计时，并且接口在超时时间内没有响应，则需要提早中断该请求并返回。
比如正常下游接口的超时时间为800ms，但是因为自身业务的特殊需求，最多只能等200ms，如果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() {
@Override
public 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中异步多线程超时导致的服务异常
在项目中为了提高大并发量时的性能稳定性,经常会使用到线程池来做多线程异步操作,多线程有2种,一种是实现runnable接口,这种没有返回值,一种是实现Callable接口,这种有返回值. 当其中一个线程超时的时候,理论上应该不 影响其他线程的执行结果,但是在项目中出现的问题表明一个线程阻塞,其他线程返回的接口都为空.其实是个很简单的问题,但是由于第一次碰到,还是想了一些时间的.很简单,就是因为阻塞的那个线 程没有释放,并发量一大,线程池数量就满了,所以其他线程都处于等待状态. 附上一段自己写的调
-
JAVA中 终止线程的方法介绍
在Java的多线程编程中,java.lang.Thread类型包含了一些列的方法start(), stop(), stop(Throwable) and suspend(), destroy() and resume().通过这些方法,我们可以对线程进行方便的操作,但是这些方法中,只有start()方法得到了保留. 在Sun公司的一篇文章<Why are Thread.stop, Thread.suspend and Thread.resume Deprecated? >中详细讲解了舍弃这些方
-
15个高级Java多线程面试题及回答
Java 线程面试问题 在任何Java面试当中多线程和并发方面的问题都是必不可少的一部分.如果你想获得任何股票投资银行的前台资讯职位,那么你应该准备很多关于多线程的问题.在投资银行业务中多线程和并发是一个非常受欢迎的话题,特别是电子交易发展方面相关的.他们会问面试者很多令人混淆的Java线程问题.面试官只是想确信面试者有足够的Java线程与并发方面的知识,因为候选人中有很多只浮于表面.用于直接面向市场交易的高容量和低延时的电子交易系统在本质上是并发的.下面这些是我在不同时间不同地点喜欢问的Jav
-
Java多线程的用法详解
1.创建线程 在Java中创建线程有两种方法:使用Thread类和使用Runnable接口.在使用Runnable接口时需要建立一个Thread实例.因此,无论是通过Thread类还是Runnable接口建立线程,都必须建立Thread类或它的子类的实例.Thread构造函数: public Thread( ); public Thread(Runnable target); public Thread(String name); public Thread(Runnable target
-
图解Java线程的生命周期
在Java中,线程有5中不同状态,分别是:新建(New).就绪(Runable).运行(Running).阻塞(Blocked)和死亡(Dead).它们之间的转换图如下: 上图有一个例外,调用yield()方法可以让当前处于运行状态的线程转入就绪状态.如果要测试某线程是否已经死亡,可以使用isAlive()方法,该方法在线程处于就绪.运行.阻塞时放回true,新建和死亡时返回false.不要试图对一个已经死亡的线程调用start()方法而重新启动,死亡就是死亡和人一样,不可能再生.还有也不要对一
-
Java线程关闭的3种方法
Java线程关闭,总的来说有3种: 1.使用状态位,这个简单,就不多说了: 复制代码 代码如下: public class Task extends Thread { private volatile boolean flag= true; public void stopTask() { flag = false; } @Override public void run() { while(flag){ /* do your no-block task */ } } } 2.当线程等待某些事件
-
java 实现线程同步的方式有哪些
什么是线程同步? 当使用多个线程来访问同一个数据时,非常容易出现线程安全问题(比如多个线程都在操作同一数据导致数据不一致),所以我们用同步机制来解决这些问题. 实现同步机制有两个方法: 1.同步代码块: synchronized(同一个数据){} 同一个数据:就是N条线程同时访问一个数据. 2. 同步方法: public synchronized 数据返回类型 方法名(){} 就是使用 synchronized 来修饰某个方法,则该方法称为同步方法.对于同步方法而言,无需显示指定同步监视器,同步
-
Java中实现线程的超时中断方法实例
背景 之前在实现熔断降级组件时,需要实现一个接口的超时中断,意思是,业务在使用熔断降级功能时,在平台上设置了一个超时时间,如果在请求进入熔断器开始计时,并且接口在超时时间内没有响应,则需要提早中断该请求并返回. 比如正常下游接口的超时时间为800ms,但是因为自身业务的特殊需求,最多只能等200ms,如果200ms之内没有数据返回,则返回降级数据.这里处理请求的线程可以看成是tomcat线程池中的一个线程,如果通过线程池返回的Future,可以很轻松的实现超时返回,但是这种情况下,并不能拿到Fu
-
Java中求最大值的4种方法实例代码
前言 本文主要给大家分享了关于java求最大值的4中方法,文中给出了完整的示例代码,下面话不多少了,来一起看看吧 示例代码: /** *@author Prannt *求最大值(或最小值) *本例以int数据类型为例,可指定其他数据类型 */ //方法一:直接法,求最小值类似 public class Deno05ArrayMax { public static void main(String[] args) { //数据类型可指定 int [] array = {5,15,20,30,100
-
Java中String的split切割字符串方法实例及扩展
目录 一.public String[] split(String regex) 二.public String[] split(String regex, int limit) 三.扩展 总结 一.public String[] split(String regex) public String[] split(String regex): 根据传入的字符串参数,作为规则,切割当前字符串 String a="198,168,10,1"; String [] arr=a.split(&
-
.net让线程支持超时的方法实例和线程在执行结束后销毁的方法
.net让线程支持超时 使用 CancellationTokenSource 复制代码 代码如下: private static void TimeoutTest1() { var cts = new CancellationTokenSource(); var thread = new Thread(() => { Console.WriteLine(String.Format("线程{0}执行中&q
-
java中的取整与四舍五入方法实例
一.java中取整数的方式 1.直接使用强制转换 public static void roundOne(){ System.out.println("正数:(int)10.12 = " + (int)10.12); System.out.println("负数:(int)-10.12 = " + (int)-10.12); System.out.println("---------------------------------"); Syst
-
java中ArrayList的两种排序方法实例
目录 前言 1.ArrayList使用排序的初衷 2.对一个ArrayList中的数组进行排序. 3.多个ArrayList中的元素进行排序 总结 前言 由于其功能性和灵活性,ArrayList是 Java 集合框架中使用最为普遍的集合类之一.ArrayList 是一种 List 实现,它的内部用一个动态数组来存储元素,因此 ArrayList 能够在添加和移除元素的时候进行动态的扩展和缩减.你可能已经使用过 ArrayList,因此我将略过基础部分.如果你对 ArrayList 还不熟悉,你可
-
Java中终止线程的三种方法
Thread.stop, Thread.suspend, Thread.resume 和Runtime.runFinalizersOnExit 这些终止线程运行的方法已经被废弃,使用它们是极端不安全的! 1.线程正常执行完毕,正常结束 也就是让run方法执行完毕,该线程就会正常结束. 但有时候线程是永远无法结束的,比如while(true). 2.监视某些条件,结束线程的不间断运行 需要while()循环在某以特定条件下退出,最直接的办法就是设一个boolean标志,并通过设置这个标志来控制循环
-
Java中分割字符串的两种方法实例详解
前言 相信大家应该都知道在java编程中,有时候我们需要把一个字符串按照某个特定字符.字母等作为截点分割这个字符串,这样我们就可以使用这个字符串的一部分或者把所有截取的内容保存到数组里等操作.下面这篇文章就给大家分享了两种分割的方法,下面来一起看看吧. 一.java.lang.String 的 split() 方法, JDK 1.4 or later public String[] split(String regex,int limit) 示例代码 public class StringSpl
-
Java中启动线程start和run的两种方法
一.区别 Java中启动线程有两种方法,继承Thread类和实现Runnable接口,由于Java无法实现多重继承,所以一般通过实现Runnable接口来创建线程.但是无论哪种方法都可以通过start()和run()方法来启动线程,下面就来介绍一下他们的区别. start方法: 通过该方法启动线程的同时也创建了一个线程,真正实现了多线程.无需等待run()方法中的代码执行完毕,就可以接着执行下面的代码.此时start()的这个线程处于就绪状态,当得到CPU的时间片后就会执行其中的run()方法.
-
聊聊Java 中的线程中断
Java如何实现线程中断? 通过调用Thread类的实例方法interrupt.如下: Thread thread = new Thread(){ @Override public void run() { if(isInterrupted()){ System.out.println("interrupt"); } } }; thread.start(); thread.interrupt(); 线程中断后线程会立即停止执行吗? NO. 而如果线程未阻塞,或未关心中断状态,则线程会正