ScheduleMaster新特性之延時任務初體驗

ScheduleMaster在上個月底更新到了2.0版本，在功能和程式碼以及文檔上都往前跨了很大一步，詳細資訊可以參考這篇文章：//www.cnblogs.com/hohoa/p/12772945.html

對ScheduleMaster還不熟悉的朋友可以先移步作者的系列文章：//www.cnblogs.com/hohoa/category/1628282.html

這次的更新點主要包含：

開發了延時任務功能。
抽象出分散式鎖服務並默認資料庫實現。
補充了單元測試。
補充了幾篇文檔。
修復了已知的bug。

其中的重頭戲自然是延時任務功能，所謂的延時任務就是在指定時刻執行指定邏輯，這在平時需求開發中是非常常見的，作為一款功能齊全的調度系統這當然也是必備的功能。

關於延時任務的實現原理我早期寫過一篇文章《採用簡易的環形延時隊列處理秒級定時任務的解決方案》來介紹，ScheduleMaster也是在這個基礎上改進而來。

當然了，其他的實現方式也還有很多，主流的實現方案可以參考下面這篇文章，整理的比較齊全：//www.cnblogs.com/vipstone/p/12696465.html

我採用的就是比較經典的時間輪演算法，原理就不再重複介紹了可以移步到我前面的文章，下面看看實現效果。

實現了什麼效果

我們先通過一段測試程式碼看看延時隊列的運行情況：

 [Fact]
 public void Run()
 {
     //初始化容器
     DelayPlanManager.Init();
     Debug.WriteLine($"延時隊列初始化完成時間：{DateTime.Now}");

     Func<DelayQueueSlot, Task> 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 = "//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秒就開始有資訊輸出，程式調式結果為：