C#基于时间轮调度实现延迟任务详解
在很多.net开发体系中开发者在面对调度作业需求的时候一般会选择三方开源成熟的作业调度框架来满足业务需求，比如Hangfire、Quartz.NET这样的框架。但是有些时候可能我们只是需要一个简易的延迟任务，这个时候引入这些框架就费力不讨好了。
最简单的粗暴的办法当然是：
Task.Run(async () =>
{
//延迟xx毫秒
await Task.Delay(time);
//业务执行
});
当时作为一个开发者，有时候还是希望使用更优雅的、可复用的一体化方案，比如可以实现一个简易的时间轮来完成基于内存的非核心重要业务的延迟调度。什么是时间轮呢，其实就是一个环形数组，每一个数组有一个插槽代表对应时刻的任务，数组的值是一个任务队列，假设我们有一个基于60秒的延迟时间轮，也就是说我们的任务会在不超过60秒(超过的情况增加分钟插槽，下面会讲)的情况下执行，那么如何实现？下面我们将定义一段代码来实现这个简单的需求
话不多说，撸代码，首先我们需要定义一个时间轮的Model类用于承载我们的延迟任务和任务处理器。简单定义如下：
public class WheelTask<T>
{
public T Data { get; set; }
public Func<T, Task> Handle { get; set; }
}
定义很简单，就是一个入参T代表要执行的任务所需要的入参，然后就是任务的具体处理器Handle。接着我们来定义时间轮本轮的核心代码：
可以看到时间轮其实核心就两个东西，一个是毫秒计时器，一个是数组插槽，这里数组插槽我们使用了字典来实现，key值分别对应0到59秒。每一个插槽的value对应一个任务队列。当添加一个新任务的时候，输入需要延迟的秒数，就会将任务插入到延迟多少秒对应的插槽内，当计时器启动的时候，每一跳刚好1秒，那么就会对插槽计数+1，然后去寻找当前插槽是否有任务，有的话就会调用ExecuteTask执行该插槽下的所有任务。
public class TimeWheel<T>
{
int secondSlot = 0;
DateTime wheelTime { get { return new DateTime(1, 1, 1, 0, 0, secondSlot); } }
Dictionary<int, ConcurrentQueue<WheelTask<T>>> secondTaskQueue;
public void Start()
{
new Timer(Callback, null, 0, 1000);
secondTaskQueue = new Dictionary<int, ConcurrentQueue<WheelTask<T>>>();
Enumerable.Range(0, 60).ToList().ForEach(x =>
{
secondTaskQueue.Add(x, new ConcurrentQueue<WheelTask<T>>());
});
}
public async Task AddTaskAsync(int second, T data, Func<T, Task> handler)
{
var handTime = wheelTime.AddSeconds(second);
if (handTime.Second != wheelTime.Second)
secondTaskQueue[handTime.Second].Enqueue(new WheelTask<T>(data, handler));
else
await handler(data);
}
async void Callback(object o)
{
if (secondSlot != 59)
secondSlot++;
else
{
secondSlot = 0;
}
if (secondTaskQueue[secondSlot].Any())
await ExecuteTask();
}
async Task ExecuteTask()
{
if (secondTaskQueue[secondSlot].Any())
while (secondTaskQueue[secondSlot].Any())
if (secondTaskQueue[secondSlot].TryDequeue(out WheelTask<T> task))
await task.Handle(task.Data);
}
}
接下来就是如果我需要大于60秒的情况如何处理呢。其实就是增加分钟插槽数组，举个例子我有一个任务需要2分40秒后执行，那么当我 插入到时间轮的时候我先插入到分钟插槽，当计时器每过去60秒，分钟插槽值+1，当分钟插槽对应有任务的时候就将这些任务从分钟插槽里弹出再入队到秒插槽中，这样一个任务会先进入插槽值=2(假设从0开始计算)的分钟插槽，计时器运行120秒后分钟值从0累加到2,2插槽的任务弹出到插槽值=40的秒插槽里，当计时器再运行40秒，刚好就可以执行这个延迟2分40秒的任务。话不多说，上代码：
首先我们将任务WheelTask增加一个Second属性，用于当任务从分钟插槽弹出来时需要知道自己入队哪个秒插槽
public class WheelTask<T>
{
...
public int Second { get; set; }
...
}
接着我们再重新定义时间轮的逻辑增加分钟插槽值以及插槽队列的部分
public class TimeWheel<T>
{
int minuteSlot, secondSlot = 0;
DateTime wheelTime { get { return new DateTime(1, 1, 1, 0, minuteSlot, secondSlot); } }
Dictionary<int, ConcurrentQueue<WheelTask<T>>> minuteTaskQueue, secondTaskQueue;
public void Start()
{
new Timer(Callback, null, 0, 1000);、
minuteTaskQueue = new Dictionary<int, ConcurrentQueue<WheelTask<T>>>();
secondTaskQueue = new Dictionary<int, ConcurrentQueue<WheelTask<T>>>();
Enumerable.Range(0, 60).ToList().ForEach(x =>
{
minuteTaskQueue.Add(x, new ConcurrentQueue<WheelTask<T>>());
secondTaskQueue.Add(x, new ConcurrentQueue<WheelTask<T>>());
});
}
...
}
同样的在添加任务的AddTaskAsync函数中我们需要增加分钟，代码改为这样，当大于1分钟的任务会入队到分钟插槽中，小于1分钟的会按原逻辑直接入队到秒插槽中：
public async Task AddTaskAsync(int minute, int second, T data, Func<T, Task> handler)
{
var handTime = wheelTime.AddMinutes(minute).AddSeconds(second);
if (handTime.Minute != wheelTime.Minute)
minuteTaskQueue[handTime.Minute].Enqueue(new WheelTask<T>(handTime.Second, data, handler));
else
{
if (handTime.Second != wheelTime.Second)
secondTaskQueue[handTime.Second].Enqueue(new WheelTask<T>(data, handler));
else
await handler(data);
}
}
最后的部分就是计时器的callback以及任务执行的部分：
async void Callback(object o)
{
bool minuteExecuteTask = false;
if (secondSlot != 59)
secondSlot++;
else
{
secondSlot = 0;
minuteExecuteTask = true;
if (minuteSlot != 59)
minuteSlot++;
else
{
minuteSlot = 0;
}
}
if (minuteExecuteTask || secondTaskQueue[secondSlot].Any())
await ExecuteTask(minuteExecuteTask);
}
async Task ExecuteTask(bool minuteExecuteTask)
{
if (minuteExecuteTask)
while (minuteTaskQueue[minuteSlot].Any())
if (minuteTaskQueue[minuteSlot].TryDequeue(out WheelTask<T> task))
secondTaskQueue[task.Second].Enqueue(task);
if (secondTaskQueue[secondSlot].Any())
while (secondTaskQueue[secondSlot].Any())
if (secondTaskQueue[secondSlot].TryDequeue(out WheelTask<T> task))
await task.Handle(task.Data);
}
基本上基于分钟+秒的时间轮延迟任务核心功能就这些了，聪明的你一定知道如何扩展增加小时，天，月份甚至年份的时间轮了。虽然从代码逻辑上可以实现，但是大部分情况下我们使用时间轮仅仅是完成一些内存易失性的非核心的任务延迟调度，实现天，周，月年意义不是很大。所以基本上到小时就差不多了。再多就上作业系统来调度吧。
到此这篇关于C#基于时间轮调度实现延迟任务详解的文章就介绍到这了,更多相关C#延迟任务内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
C#的path.GetFullPath 获取上级目录实现方法
这篇文章主要介绍了C#的path.GetFullPath 获取上级目录实现方法,包含了具体的C#实现方法以及ASP.net与ASP等的方法对比,非常具有实用价值,需要的朋友可以参考下2014-10-10
这篇文章主要介绍了c# 读取XML文件的示例，帮助大家更好的理解和使用c# 编程语言，感兴趣的朋友可以了解下。2020-11-11
这篇文章介绍了C#使用正则表达式的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-04-04
这篇文章主要为大家详细介绍了Silverlight实现跑马灯动画，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-07-07
其实说白了，反射就是能知道我们未知类型的类型信息这么一个东西．没什么神秘可讲！反射的核心是System.Type。System.Type包含了很多属性和方法，使用这些属性和方法可以在运行时得到类型信息2013-07-07
这篇文章主要为大家介绍了C#实现接口base调用示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-06-06
这篇文章主要介绍了C# yield在WCF中的错误使用（一）,本文讲解的内容据说是99%的开发人员都有可能犯的错误,需要的朋友可以参考下2015-04-04
这篇文章主要为大家详细介绍了C# SendMail发送邮件功能实现，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-06-06
在C#到底该如何安全的调用这样的DLL接口函数呢？本文将详细介绍如何调用各种参数的方法，对C#结构体指针DLL相关知识感兴趣的朋友一起看看吧2021-07-07
本文主要介绍了C#调用js库的方法小结，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-04-04
最新评论