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#实现批量给图片添加水印的功能，文中的示例代码讲解详细，对我们学习C#有一定的帮助，感兴趣的小伙伴可以了解一下2022-12-12
这篇文章主要介绍了C#如何动态创建lambda表达式问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-02-02
本篇文章是对c#中利用API函数实现动画窗体的方法进行了详细的分析介绍，需要的朋友参考下2013-06-06
在本篇文章里小编给大家整理的是关于c# this关键字用法以及相关实例代码，有兴趣的朋友们可以学习下。2020-02-02
在程序执行中会遇到启动本软件的exe问，或者启用其它的exe文件，已达到执行某些操作的作用。下面是两种最常见的启动exe文件。2013-04-04
C#将DataGridView中的数据保存到CSV和Excel中
这篇文章介绍了C#将DataGridView中的数据保存到CSV和Excel中的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-04-04
这篇文章主要介绍了C#命名空间与java包的区别,较为详细的分析了C#命名空间与java包的相同点与不同点,非常具有实用价值,需要的朋友可以参考下2015-04-04
这篇文章主要介绍了C#自定义控件添加右键菜单的方法，本文用到control控件，专门自定义右键菜单，下面小编给大家整理下，有需要的小伙伴可以来参考下2015-08-08
这篇文章主要给大家介绍了关于C# webApi创建与发布、部署、api调用的相关资料,WebApi是微软在VS2012 MVC4版本中绑定发行的,WebApi是完全基于Restful标准的框架,文中通过图文介绍的非常详细,需要的朋友可以参考下2023-12-12
这篇文章主要为大家详细介绍了Unity实现鼠标拖动3D物体，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2020-10-10
最新评论