时间:2021-05-20
本文实例展示的是一个自定义的定时器组件,有别于.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));elsesleepTime = SleepTimeProvider.Defult.InnerFixBuilder(TimePointConvert.Default.ConvertCircle(normalCycle));if (sleepTime.TotalMilliseconds > 0)Thread.Sleep(sleepTime);}#endregionwhile (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));}}#endregionif (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);}感兴趣的朋友可以测试一下本文所述实例代码,相信会有不小的收获!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
本文实例讲解了C#实现ProperTyGrid自定义属性的方法,分享给大家供大家参考。具体方法如下:一般来说,C#如果要实现自定义属性必须要需要实现接口ICus
本文实例讲述了asp.net中c#自定义事件的实现方法。分享给大家供大家参考。具体分析如下:c#自定义事件分为六步,声明关于事件的委托,声明事件,编写引发事件的
本文实例讲述了C#自定义序列化ISerializable的实现方法。分享给大家供大家参考。具体实现方法如下:[Serializable]publicclassB
本文实例讲述了C#自定义签名章实现方法。分享给大家供大家参考。具体实现方法如下:usingSystem;usingSystem.Collections.Gene
本文实例讲述了C#自定义基于控制台的Timer实现方法。分享给大家供大家参考。具体如下:一、概述这里实现了一个自定义类TimerTest,该类可以模拟一个Tim