Java并发编程—如何实现线程的超时中断

原文作者：大老二在不在

原文地址：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() {@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并发编程实践(2)线程安全性
[0]README 0.0)本文部分文字描述转自:"java并发编程实战", 旨在学习"java并发编程实践(2)线程安全性" 的相关知识: 0.1)几个术语( ...
Java并发编程—什么是线程？
原文作者:way_more 原文地址:Java 多线程常见基础面试题总结,面试必看! 目录一.什么是线程和进程? 二.简要描述线程与进程的关系三.FAQ 一.什么是线程和进程? 1.1. 何为进程 ...
java并发编程第一课线程的创建、停止和状态变更
开篇词: 由点及面,搭建你的 Java 并发知识网你好,欢迎学习<Java 并发编程核心 78 讲>,我是讲师星星,一线互联网公司资深研发工程师,参与过集团内多个重点项目的设计与开发. ...
Java并发编程(01)：线程的创建方式，状态周期管理
本文源码:GitHub·点这里 || GitEE·点这里一.并发编程简介 1.基础概念程序与计算机系统操作有关的计算机程序.规程.规则,以及可能有的文件.文档及数据. 进程进程是计算机中的程序 ...
Java并发编程 synchronized保证线程安全的原理
文章转载致博客 blog.csdn.net/javazejian/- 自己稍加完善. 线程安全是并发编程中的重要关注点,应该注意到的是,造成线程安全问题的主要诱因有两点,一是存在共享数据(也称临界资源 ...
Java并发编程(02)：线程核心机制，基础概念扩展
本文源码:GitHub·点这里 || GitEE·点这里一.线程基本机制 1.概念描述并发编程的特点是:可以将程序划分为多个分离且独立运行的任务,通过线程来驱动这些独立的任务执行,从而提升整体的效 ...
Java并发编程(04)：线程间通信，等待/通知机制
本文源码:GitHub·点这里 || GitEE·点这里一.概念简介 1.线程通信在操作系统中,线程是个独立的个体,但是在线程执行过程中,如果处理同一个业务逻辑,可能会产生资源争抢,导致并发问题, ...
java并发编程第二课线程锁和线程安全
第04讲:waitnotifynotifyAll 方法的使用注意事项? 本课时我们主要学习 wait/notify/notifyAll 方法的使用注意事项. 我们主要从三个问题入手: 为什么 wait ...
[Java 并发编程实战] 设计线程安全的类的三个方式(含代码)
发奋忘食,乐以忘优,不知老之将至.---<论语> 前面几篇已经介绍了关于线程安全和同步的相关知识,那么有了这些概念,我们就可以开始着手设计线程安全的类.本文将介绍构建线程安全类的几个方法, ...

Java并发编程—如何实现线程的超时中断

背景

思路

实现

Java并发编程—如何实现线程的超时中断相关推荐

最新文章

热门文章