监控任务是否超时，超时则结束任务

参考redis实现分布式锁的方式，使用看门狗的方式来执行具体任务

看门狗线程一般不是工作线程，而是监控线程，

但是我们需要执行的任务应该在子线程执行，而主线程应该等待子线程执行结果，

因此，使用看门狗线程执行具体任务，主线程循环轮询，是否子线程返回结果；

具体实现如下：

package com.test;import java.util.Arrays;
import java.util.function.Function;/*** @author yangguang* @date 2023年05月12日 13:52*/
public class Test {private int timeout;private Function<String[],Integer> taskFunction;private Thread taskThread;private volatile Thread currentThread;private String[] param;private volatile Integer result;public Test(int timeout,String[] param,Function<String[],Integer> taskFunction) {this.timeout = timeout;this.taskFunction = taskFunction;this.param = param;this.currentThread = Thread.currentThread();}public Integer startTask() {taskThread = new Thread(()->{result = taskFunction.apply(param);currentThread.interrupt();});taskThread.start();while (true) {try {Thread.sleep(timeout);System.out.println("第三方接口调用超时");taskThread.stop();return -1;} catch (InterruptedException e) {System.out.println("第三方接口调用正常返回");return result;}}}private static Function<String[],Integer> apiService(){return param->{try {//调用第三方接口System.out.println("接口参数为"+ Arrays.toString(param));Thread.sleep(2000);} catch (Exception e) {e.printStackTrace();}return 1;};}public static void main(String[] args) {Test test = new Test(3000,new String[]{"参数1","参数2"},apiService());Integer r = test.startTask();System.out.println("第三方接口返回结果为"+r);test = new Test(1000,new String[]{"参数1","参数2"},apiService());r = test.startTask();System.out.println("第三方接口返回结果为"+r);}}

监控任务是否超时，超时则结束任务相关推荐

mysql 连接 110 超时_Nginx和mysql上行超时超时（110:连接超时）
我的堆栈是带gevent循环.flask.mysql和python mysql.connector的uWSGI,我可以进行异步mysql查询.Lateley我在运行查询时在nginx日志中发现了以下错 ...
linux shell curl 超时与重试
目录 curl 关于时间控制和重试的参数连接超时参数 connect-timeout 请求超时时间 --max-time 请求重试 retry 重试超时时间 retry-max-time 重试延迟 ...
TCP/IP详解--学习笔记(12)-TCP的超时与重传
超时重传是TCP协议保证数据可靠性的另一个重要机制,其原理是在发送某一个数据以后就开启一个计时器,在一定时间内如果没有得到发送的数据报的ACK报文,那么就重新发送数据,直到发送成功为止. 1.超时超 ...
TCP/IP详解学习笔记(12)-TCP的超时与重传
超时重传是TCP协议保证数据可靠性的另一个重要机制,其原理是在发送某一个数据以后就开启一个计时器,在一定时间内如果没有得到发送的数据报的ACK报文,那么就重新发送数据,直到发送成功为止. 1.超时超 ...
CSocket类的Receive超时的问题解决方案
前几日碰到一问题,当CSocket的Receive阻塞时,如何进行超时处理.由于程序是在多线程中使用Socket通信,开始时是在主线程中用定时监测Receive函数,当超时后,结束通信.但问题是CSo ...
Golang中WaitGroup、Context、goroutine定时器及超时学习笔记
原文连接:http://targetliu.com/2017/5/2... 好久没有发过文章了 - -||,今天发一篇 golang 中 goroutine 相关的学习笔记吧,以示例为主. WaitG ...
poj java 输入超时_Java：如何实现代码超时功能？
我们写一个有超时功能的 Callable: import java.util.concurrent.*; public class TimeoutCallable implements Callabl ...
【韧性设计】韧性设计模式：重试、回退、超时、断路器
什么是韧性? 软件本身并不是目的:它支持您的业务流程并使客户满意.如果软件没有在生产中运行,它就无法产生价值.然而,生产性软件也必须是正确的.可靠的和可用的. 当谈到软件设计中的弹性时,主要目标是构建 ...
Python笔记_84_我的订单_使用celery完成订单超时_视频播放_使用保利威视频加密
文章目录我的订单后端提供查询当前登录用户的订单列表信息前端请求获取当前登录用户的订单信息订单状态显示分析使用Celery的定时任务来完成订单超时功能视频播放使用保利威云视频服务来对视频进 ...
生产事故总结篇(2) 接口响应超时优化方案
1 查询类接口一 mysql数据库查询超时问题 1 查询字段是否存在索引,索引是否失效索引是个老生常谈的问题了, 需要特别注意下面几个点唯一的值必须要建立唯一索引比如订单号,售后单号,上门取件 ...

监控任务是否超时，超时则结束任务

监控任务是否超时，超时则结束任务相关推荐

最新文章

热门文章