C#实现自定义定时组件的方法

 更新时间:2014年08月15日 10:48:33   投稿:shichen2014  
这篇文章主要介绍了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);
}

  感兴趣的朋友可以测试一下本文所述实例代码,相信会有不小的收获!

相关文章

  • WPF实现窗体中的悬浮按钮

    WPF实现窗体中的悬浮按钮

    这篇文章主要为大家详细介绍了WPF实现窗体中的悬浮按钮,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-11-11
  • C#实现串口示波器

    C#实现串口示波器

    这篇文章主要为大家详细介绍了C#实现串口示波器,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-02-02
  • 浅谈c# 浮点数计算

    浅谈c# 浮点数计算

    本文通过具体的示例给大家演示了下C#中浮点数运算所遇到的问题及解决方法,有需要的小伙伴可以参考下
    2017-09-09
  • C#保存listbox中数据到文本文件的方法

    C#保存listbox中数据到文本文件的方法

    这篇文章主要介绍了C#保存listbox中数据到文本文件的方法,涉及C#操作listbox数据的相关技巧,需要的朋友可以参考下
    2015-04-04
  • C# WPF Image控件的绑定方法

    C# WPF Image控件的绑定方法

    这篇文章主要介绍了C# WPF Image控件的绑定方法,帮助大家更好的理解和学习使用c#,感兴趣的朋友可以了解下
    2021-03-03
  • C#中数组初始化与数组元素复制的方法

    C#中数组初始化与数组元素复制的方法

    这篇文章主要介绍了C#中数组初始化与数组元素复制的方法,涉及C#中数组的创建、初始化及使用Array.Copy方法复制数组元素的技巧,需要的朋友可以参考下
    2015-04-04
  • 浅析C#更改令牌ChangeToken

    浅析C#更改令牌ChangeToken

    这篇文章主要介绍了C#更改令牌ChangeToken,文中运用大量代码讲解的非常详细,感兴趣的小伙伴一起来看看这篇文章吧
    2021-09-09
  • c#实现抓取高清美女妹纸图片

    c#实现抓取高清美女妹纸图片

    本文给大家分享的是一则使用c#实现抓取网络高清美女妹纸图片的代码,这么好的东西,当然不能独享,推荐给小伙伴们。
    2015-03-03
  • 使用C#语言实现的查询条件界面展开和收起功能

    使用C#语言实现的查询条件界面展开和收起功能

    这篇文章主要介绍了使用C#语言实现的查询条件界面展开和收起功能的完美解决方案,需要的朋友可以参考下
    2016-11-11
  • C#读写Config配置文件案例

    C#读写Config配置文件案例

    这篇文章介绍了C#读写Config配置文件的方法,文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-04-04

最新评论