ScheduleMaster新特性之延時任務初體驗
阿新 • • 發佈：2020-05-19
ScheduleMaster在上個月底更新到了2.0版本，在功能和程式碼以及文件上都往前跨了很大一步，詳細資訊可以參考這篇文章：https://www.cnblogs.com/hohoa/p/12772945.html
對ScheduleMaster還不熟悉的朋友可以先移步作者的系列文章：https://www.cnblogs.com/hohoa/category/1628282.html
這次的更新點主要包含：
- 開發了延時任務功能。
- 抽象出分散式鎖服務並預設資料庫實現。
- 補充了單元測試。
- 補充了幾篇文件。
- 修復了已知的bug。
其中的重頭戲自然是延時任務功能，所謂的延時任務就是在指定時刻執行指定邏輯，這在平時需求開發中是非常常見的，作為一款功能齊全的排程系統這當然也是必備的功能。
關於延時任務的實現原理我早期寫過一篇文章[《採用簡易的環形延時佇列處理秒級定時任務的解決方案》](https://www.cnblogs.com/hohoa/p/7739271.html)來介紹，ScheduleMaster也是在這個基礎上改進而來。
當然了，其他的實現方式也還有很多，主流的實現方案可以參考下面這篇文章，整理的比較齊全：https://www.cnblogs.com/vipstone/p/12696465.html
我採用的就是比較經典的時間輪演算法，原理就不再重複介紹了可以移步到我前面的文章，下面看看實現效果。
### 實現了什麼效果 我們先通過一段測試程式碼看看延時佇列的執行情況： ```c# [Fact] public void Run() { //初始化容器 DelayPlanManager.Init(); Debug.WriteLine($"延時佇列初始化完成時間：{DateTime.Now}"); Func callback = (result) =>
{
var np = result as NotifyPlan;
//模擬業務
Debug.WriteLine($"[{DateTime.Now}]ID：{np.Key}，地址：{np.NotifyUrl}，延遲秒數：{np.TimeSpan}");
return Task.CompletedTask;
};
//模擬生產端寫入任務
Task[] tasks = new Task[10];
for (int i = 0; i < 10; i++)
{
tasks[i] = new Task(() =>
{
for (int k = 0; k < 200; k++)
{
int rndNum = new Random().Next(20, 500);
DelayPlanManager.Insert(new NotifyPlan
{
NotifyUrl = "http://localhost:56655/api/1.0/value/delaypost",
Key = Guid.NewGuid().ToString(),
Callback = callback
}, DateTime.Now.AddSeconds(rndNum));
}
}, TaskCreationOptions.LongRunning);
tasks[i].Start();
}
Task.WaitAll(tasks);
//構造消費者
while (true)
{
DelayPlanManager.Read();
System.Threading.Thread.Sleep(1000);
}
}
```
程式碼中建立了2000個延時任務，延時範圍在20秒至500秒，所以我們預測在程式啟動後最快20秒就開始有資訊輸出，程式調式結果為：
當一個週期執行完後剛好過了1分鐘：
分秒不差。
### 實現了什麼效果 我們先通過一段測試程式碼看看延時佇列的執行情況： ```c# [Fact] public void Run() { //初始化容器 DelayPlanManager.Init(); Debug.WriteLine($"延時佇列初始化完成時間：{DateTime.Now}"); Func