C# 看门狗策略实现

news2025/4/19 14:45:32
using System;
using System.Threading;

public class Watchdog
{
    private Timer _timer;
    private volatile bool _isTaskAlive;
    private readonly object _lock = new object();
    private const int CheckInterval = 5000; // 5秒检测一次
    private const int TimeoutThreshold = 10000; // 10秒无响应判定为超时

    // 被监控的任务(示例用线程模拟)
    private Thread _monitoredTask;
    private DateTime _lastHeartbeat;

    public void Start()
    {
        // 启动被监控的任务
        _monitoredTask = new Thread(MonitoredTaskWork);
        _monitoredTask.Start();

        // 初始化看门狗定时器
        _timer = new Timer(CheckStatus, null, CheckInterval, Timeout.Infinite);
    }

    // 被监控的任务模拟(需定期发送心跳)
    private void MonitoredTaskWork()
    {
        try
        {
            while (true)
            {
                // 模拟工作逻辑
                Thread.Sleep(1000);

                // 发送心跳
                lock (_lock)
                {
                    _lastHeartbeat = DateTime.Now;
                }
            }
        }
        catch (ThreadAbortException)
        {
            // 任务被终止时清理
        }
    }

    // 看门狗状态检查
    private void CheckStatus(object state)
    {
        lock (_lock)
        {
            if ((DateTime.Now - _lastHeartbeat).TotalMilliseconds > TimeoutThreshold)
            {
                Console.WriteLine("⚠️ 任务无响应,触发重启...");
                RestartTask();
            }
        }

        // 重置定时器(单次触发模式)
        _timer.Change(CheckInterval, Timeout.Infinite);
    }

    // 重启任务
    private void RestartTask()
    {
        try
        {
            if (_monitoredTask != null && _monitoredTask.IsAlive)
            {
                _monitoredTask.Abort();
                _monitoredTask.Join(1000);
            }
        }
        finally
        {
            _monitoredTask = new Thread(MonitoredTaskWork);
            _monitoredTask.Start();
            _lastHeartbeat = DateTime.Now;
        }
    }

    // 停止看门狗
    public void Stop()
    {
        _timer?.Dispose();
        _monitoredTask?.Abort();
    }
}

// 使用示例
class Program
{
    static void Main()
    {
        var watchdog = new Watchdog();
        watchdog.Start();

        Console.WriteLine("看门狗已启动,按任意键退出...");
        Console.ReadKey();

        watchdog.Stop();
    }
}

核心设计要点:

  1. 心跳机制
    被监控的任务需定期更新 _lastHeartbeat(示例中每1秒更新一次),看门狗通过检查心跳时间判断是否存活。

  2. 超时判定
    若超过 TimeoutThreshold(示例10秒)未收到心跳,判定为任务冻结,触发重启。

  3. 安全重启

    • 使用 Thread.Abort() + Join() 确保旧任务终止

    • 创建新线程并更新心跳时间戳

  4. 线程安全

    • 使用 lock 保护共享数据 _lastHeartbeat

    • volatile 关键字确保布尔标志的可见性

  5. 定时器模式
    采用单次触发定时器Timeout.Infinite),每次检测后重置,避免并发问题。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/2332447.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

ISP--Demosaicking

文章目录 前言算法解释简单的线性插值代码实现 色差法和色比法基于方向加权的方法RB缺失的G通道的插值RB缺失的BR的插值G缺失的BR的插值代码实现 基于边缘检测的方法计算缺失的G计算缺失的RB值/计算缺失的G值 前言 人眼之所以有能感受到自然界的颜色,是因为人眼的感…

国标GB28181协议EasyCVR视频融合平台:5G时代远程监控赋能通信基站安全管理

一、背景介绍 随着移动通信行业的迅速发展,无人值守的通信基站建设规模不断扩大。这些基站大多建于偏远地区,周边人迹罕至、交通不便,给日常的维护带来了极大挑战。其中,位于空旷地带的基站设备,如空调、蓄电池等&…

模拟-与-现实协同训练:基于视觉机器人操控的简单方法

25年3月来自 UT Austin、Nvidia、UC Berkeley 和纽约大学的论文“Sim-and-Real Co-Training: A Simple Recipe for Vision-Based Robotic Manipulation”。 大型现实世界机器人数据集在训练通才机器人模型方面拥有巨大潜力,但扩展现实世界人类数据收集既耗时又耗资…

WRS-PHM电机智能安康系统:为浙江某橡胶厂构筑坚实的生产防线

以行业工况为背景 一、顾客工厂的背景 浙江某橡胶厂以电机为中心生产设备必须连续平稳运行。但由于缺乏有效的故障预警体系,电机故障就像潜伏着的“不定时炸弹”,不但不时地造成生产流程的中断,也使对生产进行管理异常艰难,对持续安全生产提…

将 CrewAI 与 Elasticsearch 结合使用

作者:来自 Elastic Jeffrey Rengifo 学习如何使用 CrewAI 为你的代理团队创建一个 Elasticsearch 代理,并执行市场调研任务。 CrewAI 是一个用于编排代理的框架,它通过角色扮演的方式让多个代理协同完成复杂任务。 如果你想了解更多关于代理…

Spring 的 IoC 和 DI 详解:从零开始理解与实践

Spring 的 IoC和 DI 详解:从零开始理解与实践 一、IoC(控制反转) 1、什么是 IoC? IoC 是一种设计思想,它的核心是将对象的创建和管理权从开发者手中转移到外部容器(如 Spring 容器)。通过这种…

ZYNQ笔记(四):AXI GPIO

版本:Vivado2020.2(Vitis) 任务:使用 AXI GPIO IP 核实现按键 KEY 控制 LED 亮灭(两个都在PL端) 一、介绍 AXI GPIO (Advanced eXtensible Interface General Purpose Input/Output) 是 Xilinx 提供的一个可…

实操(环境变量)Linux

环境变量概念 我们用语言写的文件编好后变成了程序,./ 运行的时候他就会变成一个进程被操作系统调度并运行,运行完毕进程相关资源被释放,因为它是一个bash的子进程,所以它退出之后进入僵尸状态,bash回收他的退出结果&…

Word / WPS 页面顶部标题 段前间距 失效 / 不起作用 / 不显示,标题紧贴页眉 问题及解决

问题描述: 在 Word 或者 WPS 里面,如果不是新的一节,而是位于新的一页首行时,不管怎么设置段前间距,始终是失效的,实际段前间距一直是零。 解决方案: 查询了很多方案均无法解决问题&#xff…

Linux自行实现的一个Shell(15)

文章目录 前言一、头文件和全局变量头文件全局变量 二、辅助函数获取用户名获取主机名获取当前工作目录获取最后一级目录名生成命令行提示符打印命令行提示符 三、命令处理获取用户输入解析命令行执行外部命令 四、内建命令添加环境变量检查和执行内建命令 五、初始化初始化环境…

在 Q3D 中提取汇流条电感

汇流条排简介和设计注意事项 汇流条排是用于配电的金属导体,在许多应用中与传统布线相比具有设计优势。在设计母线排时,必须考虑几个重要的因素: 低电感:高频开关内容会导致无功损耗,从而降低效率电容:管…

MySQL:事务的理解

一、CURD不加控制,会有什么问题 (1)因为,MySQL里面存的是数据,所以很有可能会被多个客户访问,所以mysqld可能一次会接受到多个关于CURD的请求。(2)且mysql内部是采用多线程来完成数…

python 基础:句子缩写

n int(input()) for _ in range(n):words input().split()result ""for word in words:result word[0].upper()print(result)知识点讲解 input()函数 用于从标准输入(通常是键盘)读取用户输入的内容。它返回的是字符串类型。例如在代码中…

Ruoyi-vue plus 5.2.2 flowble 结束节点异常错误

因业务要求, 我在结束节点的结束事件中,制作了一个归档的事件,来执行一个业务。 始终都会报错, 错误信息 ${archivTemplateListener} did not resolve to an implementation of interface org.flowable.engine.delegate.Execution…

Sublime Text使用教程(用Sublime Text编写C语言程序)

Sublime Text 是一款当下非常流行的文本编辑器,其功能强大(提供有众多的插件)、界面简洁、还支持跨平台使用(包括 Mac OS X、Linux 和 Windows)。 在程序员眼中,Sublime Text 不仅仅是一个文本编辑器&…

【1】k8s集群管理系列--包应用管理器之helm

一、helm概述 Helm核心是模板,即模板化K8s YAML文件。 通过模板实现Chart高效复用,当部署多个应用时,可以将差异化的字段进行模板化,在部署时使用-f或 者–set动态覆盖默认值,从而适配多个应用 helm工作流程&#xf…

Mysql表的操作(2)

1.去重 select distinct 列名 from 表名 2.查询时排序 select 列名 from 表名 order by 列名 asc/desc; 不影响数据库里面的数据 错误样例 : 但结果却有点出乎意料了~为什么会失败呢? 其实这是因为书写的形式不对,如果带了引号,…

智能物联网网关策略部署

实训背景 某智慧工厂需部署物联网网关,实现以下工业级安全管控需求: 设备准入控制:仅允许注册MAC地址的传感器接入(白名单:AA:BB:CC:DD:EE:FF)。协议合规性:禁止非Modbus TCP(端口…

Java学习总结-线程池

线程池是什么? 线程池就是一个可以复用线程的技术。 假若不用线程池的问题:创建新线程开销很大,不能来一个任务就就创建一个新线程。 如何创建线程池对象? 方法一:使用ExecutorService的实现类ThreadPoolExecutor创…

基于CNN-BiLSTM-GRU的深度Q网络(Deep Q-Network,DQN)求解移动机器人路径规划,MATLAB代码

一、深度Q网络(Deep Q-Network,DQN)介绍 1、背景与动机 深度Q网络(DQN)是深度强化学习领域的里程碑算法,由DeepMind于2013年提出。它首次在 Atari 2600 游戏上实现了超越人类的表现,解决了传统…