C#实现自定义定时组件的方法
本文实例展示的是一个自定义的定时器组件,有别于.NET Framework里面提供的几个Timer。首先说说该组件开发背景,发现现在手头上的工作离不开定时,定时做一个任务,什么都是定时去做什么什么,隔某段时间干某件事情,都离不开“定时”这个词。众所周知这个要用到多线程,在多篇关于多线程的文章里面有提过做一些周期性的操作时最好用Timer,当然这个Timer肯定是Threading.Timer,并不是WinForm控件里面的Timer。但我觉得在我的应用中Timer不够满足需求。
1.Timer只能在做任务与任务之间相隔一段时间的操作,如下图
但我需要的是这次任务开始的时刻到下次任务开始时刻是相隔同等的时间,又如下图
这样的情况下Timer则不能满足需求。
2.Timer的时间间隔一般是定的,但是如果要每次执行完任务要变动一下休眠的时间, 则需要调用Timer的Change方法。
3.Timer的休眠时间不是通过整形确定休眠的毫秒数,就是用一个TimeSpan来确定,对于那种到每天多少多少时刻或者到每小时的多少分执行一次的任务来说也不能够完全方便使用
对于上面这三种,笔者对定时器封装了一下,弃用了Timer,还是用回了原有的Thread,定义了一种描述重复时间的模式字符串,计算出TimeSpan,从而调用Thread的Sleep()方法来休眠。下面展示整个组件的类图
最底下是两个关于时间计算方面的类,两个代理是两种任务方法的委托,基类BaseCycleMission是周期任务的积累,实现了ICycle接口,主要进行对任务线程的操控(开始,停止等),继承他的两个子类一个是实现上文第一点中我后来描述那种需求,一个类似于原有Timer的功能。它们各自使用不同的委托。MissionManager只是对所有周期任务的一个管理,统一去开启或暂停某一类的任务。
时间计算模块
那首先来介绍一下定义的字符串模式。现在遇到的周期是有两种模式,
一种是每隔多长时间要执行一次的任务,这个是最普通的周期形式,以每个5分钟为例,完整的形式是“-99--99--99 -99:05:00”,“-99”是缺省的意思,当然还有其他简写的模式;
另一种是没到什么什么时候执行一次任务,例如没到中午12点为例完整的形式是“ff-ff-ff 12: ff:ff”,“ff”是默认的形式,当然也可以用“FF”,这里也有其他简写的模式。
所有字符串的模式如下表所示
每到***时刻 | 每隔***时间 | |
完整 | ffff-ff-ff ff:ff:ff 或 ff-ff-ff ff:ff:ff |
-99--99--99 -99:-99:-99 |
日期部分 | ffff-ff-ff 或 ff-ff-ff |
-99--99--99 |
时间部分 | ff:ff:ff 或 ff:ff:ff |
-99:-99:-99 |
时间简写 | ff:ff 或 ff:ff |
-99:-99 |
那么时间计算模块的处理流程是,给定了相应的模式字符串,TimePointConverter借助正则表达式匹配出对应的模式,返回匹配出来的年月日时分秒各个值,得出结果之后就调用SleepTimeProvider来计算出线程所要休眠的时间。下面则展示一下两个类的部分代码
public class TimePointConverter { //其他成员 private int[] DateTimeFixBuilder(string timeStr) { int[] result = null; string[] dtArray = timeStr.Split(); string[] dateArray = dtArray[0].Split('-'); string[] timeArray = dtArray[1].Split(':'); uint year,month,date; uint hour, minute, second; uint.TryParse(dateArray[0], out year); uint.TryParse(dateArray[1], out month); uint.TryParse(dateArray[2], out date); uint.TryParse(timeArray[0], out hour); uint.TryParse(timeArray[1], out minute); uint.TryParse(timeArray[2], out second); //return InnerFixBuilder(year, month, date, hour, minute, second); result = new int[] { (int)year, (int)month, (int)date, (int)hour, (int)minute, (int)second }; return result; } //其他成员 }
public class SleepTimeProvider { //其他成员 public TimeSpan InnerFixBuilder(uint year, uint month, uint date, uint hour, uint minute, uint second) { uint[] uintTimeArray = new uint[6] { year, month, date, hour, minute, second }; int[] intNowArray = new int[6] { DateTime.Now.Year,DateTime.Now.Month,DateTime.Now.Day, DateTime.Now.Hour,DateTime.Now.Minute,DateTime.Now.Second }; int[] intTimeArray = new int[6]; intTimeArray[0] = uintTimeArray[0] == 0 ? -DateTime.Now.Year : (int)uintTimeArray[0]; for (int i = 1; i < uintTimeArray.Length; i++) { intTimeArray[i] = intTimeArray[i - 1] < 0 && uintTimeArray[i] == 0 ? -intNowArray[i] : (int)uintTimeArray[i]; } DateTime goalTime = new DateTime(Math.Abs(intTimeArray[0]), Math.Abs(intTimeArray[1]), Math.Abs(intTimeArray[2]), Math.Abs(intTimeArray[3]), Math.Abs(intTimeArray[4]), Math.Abs(intTimeArray[5])); if (goalTime < DateTime.Now) { int max = -1; for (int i = intTimeArray.Length - 1; i >= 0; i--) { if (intTimeArray[i] < 0 && i > max) { max = i; intTimeArray[i]--; } intTimeArray[i] = Math.Abs(intTimeArray[i]); } goalTime = new DateTime(Math.Abs(intTimeArray[0]), Math.Abs(intTimeArray[1]), Math.Abs(intTimeArray[2]), Math.Abs(intTimeArray[3]), Math.Abs(intTimeArray[4]), Math.Abs(intTimeArray[5])); } return goalTime - DateTime.Now; } //其他成员 }
线程调用模块
线程调用模块是任务执行的核心部分,MissionEntiy是对线程操作的封装,主要负责开始,停止,暂停等操作。Thread用的是后台线程,对线程操作时也多做几个判断。例如暂停那个操作的定义如下
public bool Pause() { if (actionThread == null) return false; if (actionThread.ThreadState == (System.Threading.ThreadState.Running | ThreadState.Background) || actionThread.ThreadState == (System.Threading.ThreadState.WaitSleepJoin | ThreadState.Background)) { actionThread.Suspend(); return true; } return false; }
CycleMission是真正的任务载体,里面都同样有对线程的操作,但是又外加了一些时间处理,最核心的是让线程的BuildMainAction方法,这个方法是计算出要休眠的时间,让线程休眠,到点时调用适当的方法委托。
public class BaseCycleMission:ICycleMission { //其他成员 protected void BuildMainAction(string normalCycle, string overTimeCycle, object overTimeDelegate, bool isSleepBefore,bool isInclude) { mainAction = () => { TimeSpan sleepTime=TimeSpan.MinValue; bool result = true; TimePointConvert.CircleType type ; #region 提前休眠 if (isSleepBefore) { type = TimePointConvert.Default.PraseType(normalCycle); if (type == TimePointConvert.CircleType.Interval) sleepTime = SleepTimeProvider.Defult.InnerIntervalBuilder( TimePointConvert.Default.ConvertCircle(normalCycle)); else sleepTime = SleepTimeProvider.Defult.InnerFixBuilder( TimePointConvert.Default.ConvertCircle(normalCycle)); if (sleepTime.TotalMilliseconds > 0) Thread.Sleep(sleepTime); } #endregion while (true) { #region 计算时间 if (isInclude) { if (result) { type = TimePointConvert.Default.PraseType(normalCycle); type = TimePointConvert.Default.PraseType(overTimeCycle); sleepTime = type == TimePointConvert.CircleType.Interval ? SleepTimeProvider.Defult.InnerIntervalBuilder( TimePointConvert.Default.ConvertCircle(overTimeCycle)) : SleepTimeProvider.Defult.InnerFixBuilder( TimePointConvert.Default.ConvertCircle(overTimeCycle)); } } #endregion #region 执行方法 if(overTimeDelegate is OverTimeCycleDelegate) result = (overTimeDelegate as OverTimeCycleDelegate).Invoke(); else { (overTimeDelegate as CycleDelegate).Invoke(); result = true; } #endregion #region 计算时间 if (!isInclude) { if (result) { type = TimePointConvert.Default.PraseType(normalCycle); sleepTime = type == TimePointConvert.CircleType.Interval ? SleepTimeProvider.Defult.InnerIntervalBuilder( TimePointConvert.Default.ConvertCircle(normalCycle)) : SleepTimeProvider.Defult.InnerFixBuilder( TimePointConvert.Default.ConvertCircle(normalCycle)); } else { type = TimePointConvert.Default.PraseType(overTimeCycle); sleepTime = type == TimePointConvert.CircleType.Interval ? SleepTimeProvider.Defult.InnerIntervalBuilder( TimePointConvert.Default.ConvertCircle(overTimeCycle)) : SleepTimeProvider.Defult.InnerFixBuilder( TimePointConvert.Default.ConvertCircle(overTimeCycle)); } } #endregion if (sleepTime.TotalMilliseconds > 0) Thread.Sleep(sleepTime); } }; } //其他成员 }
当然调用不是调用这个方法,调用只是调用它两个几类ExceptCycleMission和IncludeCycleMission,分别代表任务执行的时间不包括在周期里面和包括在周期里面两种。
管理器部分
管理器主要是一个字典集,是一个ICycleMission和字符串的字典集,里面包含了对集合里面所有元素的操作:增加,删除,运行,恢复,暂停,停止。除了删除和增加,其他都包含了类似下面的方法
RunAllMission() RunAllIncludeCycleMission() RunAllExceptCycleMission() RunMissionAmong(params string[] missionNames) RunMissionExcept(params string[] missionNames)
但是这堆方法里面都调用了CallAction这个方法,
private void CallAction(IEnumerable<ICycleMission> missionCollection,Action method) { if (missionCollection == null || method == null||missionCollection.Count()==0) return; foreach (ICycleMission item in missionCollection) { method.Method.Invoke(item, null); } }
例如在RunAllExceptCycleMission()方法里面调用如下
public void RunAllExceptCycleMission() { CallAction(this.Values.Where(c => c is ExceptCycleMission), BaseCycleMission.Default.RunMission); }
感兴趣的朋友可以测试一下本文所述实例代码,相信会有不小的收获!
相关文章
- 我们在使用C#做项目的时候,基本上都需要制作登录界面,那么今天我们就来一步步看看,如果简单的实现登录界面呢,本文给出2个例子,由简入难,希望大家能够喜欢。...2020-06-25
- 这篇文章主要介绍了C# 字段和属性的的相关资料,文中示例代码非常详细,供大家参考和学习,感兴趣的朋友可以了解下...2020-11-03
- 这篇文章主要介绍了C#中截取字符串的的基本方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-11-03
- 本文给大家分享C#连接SQL数据库和查询数据功能的操作技巧,本文通过图文并茂的形式给大家介绍的非常详细,需要的朋友参考下吧...2021-05-17
php 中file_get_contents超时问题的解决方法
file_get_contents超时我知道最多的原因就是你机器访问远程机器过慢,导致php脚本超时了,但也有其它很多原因,下面我来总结file_get_contents超时问题的解决方法总结。...2016-11-25- 这篇文章主要介绍了C#实现简单的Http请求的方法,以实例形式较为详细的分析了C#实现Http请求的具体方法,需要的朋友可以参考下...2020-06-25
- 本文主要介绍了C#中new的几种用法,具有很好的参考价值,下面跟着小编一起来看下吧...2020-06-25
使用Visual Studio2019创建C#项目(窗体应用程序、控制台应用程序、Web应用程序)
这篇文章主要介绍了使用Visual Studio2019创建C#项目(窗体应用程序、控制台应用程序、Web应用程序),小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧...2020-06-25- 这篇文章主要介绍了C#开发Windows窗体应用程序的简单操作步骤,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-04-12
- php如何实现抓取网页图片,相较于手动的粘贴复制,使用小程序要方便快捷多了,喜欢编程的人总会喜欢制作一些简单有用的小软件,最近就参考了网上一个php抓取图片代码,封装了一个php远程抓取图片的类,测试了一下,效果还不错分享...2015-10-30
- 这篇文章主要介绍了C#从数据库读取图片并保存的方法,帮助大家更好的理解和使用c#,感兴趣的朋友可以了解下...2021-01-16
- 最近做一个小项目不可避免的需要前端脚本与后台进行交互。由于是在asp.net中实现,故问题演化成asp.net中jiavascript与后台c#如何进行交互。...2020-06-25
- 这篇文章主要用实例讲解C#递归算法的概念以及用法,文中代码非常详细,帮助大家更好的参考和学习,感兴趣的朋友可以了解下...2020-06-25
- 本文通过例子,讲述了C++调用C#的DLL程序的方法,作出了以下总结,下面就让我们一起来学习吧。...2020-06-25
- 轻松学习C#的基础入门,了解C#最基本的知识点,C#是一种简洁的,类型安全的一种完全面向对象的开发语言,是Microsoft专门基于.NET Framework平台开发的而量身定做的高级程序设计语言,需要的朋友可以参考下...2020-06-25
- 相信很多站长都遇到过这样一个问题,访问页面时出现408错误,下面一聚教程网将为大家介绍408错误出现的原因以及408错误的解决办法。 HTTP 408错误出现原因: HTT...2017-01-22
- 本文主要介绍了C#变量命名规则小结,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2021-09-09
- 这篇文章主要介绍了c#中(&&,||)与(&,|)的区别详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-06-25
- 本文主要介绍了C# 中取绝对值的函数。具有很好的参考价值。下面跟着小编一起来看下吧...2020-06-25
- 这篇文章主要介绍了C#绘制曲线图的方法,以完整实例形式较为详细的分析了C#进行曲线绘制的具体步骤与相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下...2020-06-25