总结

thread

task

例子

刷新时间

  1. private void FreshTime()
  2. {
  3.     #region 刷新事件
  5.     Thread t = new Thread(delegate ()
  6.     {
  7.         isFresh = true;
  8.         while (isFresh)
  9.         {
  10.             Invoke(new EventHandler(delegate
  11.             {
  12.                 main_footer_lblTime.Text = GetDate() + DateTime.Now.ToString("HH:mm:ss");
  13.             }));
  14.             Thread.Sleep(500);
  15.         }
  16.     });
  17.     t.IsBackground = false;
  18.     t.Start();
  20.     #endregion
  21. }

定时任务

  1. /// <summary>
  2. /// 自动灌溉程序线程
  3. /// </summary>
  4. Thread programIrrigateThread = null;
  6. public void ProgramThreadTask()
  7. {
  8.     Panda.Framework.Helper.ConsoleHelper.WriteInfoLine("==》自动化灌溉启动");
  10.     programIrrigateThread = new Thread(ProgramThread);
  11.     programIrrigateThread.Start();
  12.     Panda.Framework.Helper.ConsoleHelper.WriteInfoLine("==》自动化灌溉已运行");
  13. }
  15. private async void SensorThread()
  16. {
  17.     #region 传感器线程
  19.     if (GloalConfigs.EnableRuningSensor)
  20.     {
  21.         return;
  22.     }
  24.     GloalConfigs.EnableRuningSensor = true;
  26.     var list = Panda.Common.Gatway.GloalConfigs.FinalDeviceList.ToList();
  28.     var removeCacheTime = DateTime.Now;
  30.     while (GloalConfigs.EnableRuningSensor)
  31.     {
  32.         #region 获取传感器数据
  34.         try
  35.         {
  36.             #region 获取传感器数据
  38.             if (Panda.Framework.Helper.TimeHelper.ExecDateDiffSecond(removeCacheTime, DateTime.Now) > 180) //600
  39.             {
  40.                 list = Panda.Common.Gatway.GloalConfigs.FinalDeviceList.ToList();
  41.                 removeCacheTime = DateTime.Now;
  42.             }
  44.             if (list == null || list.Count == 0)
  45.             {
  46.                 continue;
  47.             }
  49.             //Panda.Framework.Helper.ConsoleHelper.WriteInfoLine("执行传感器数据采集");
  51.             var finalDeviceList = list.FindAll(m => GloalConfigs.Gatway.GatwayInfo.GatCode == m.GatwayCode);
  52.             if (finalDeviceList == null || finalDeviceList.Count == 0)
  53.             {
  54.                 continue;
  55.             }
  57.             foreach (var s in finalDeviceList)
  58.             {
  59.                 await Task.Delay(500);
  61.                 switch (s.Category)
  62.                 {
  63.                     case "A00001002":
  64.                         #region 流量传感器
  66.                         if (s.Enable == 1)
  67.                         {
  68.                             await SensorOperatorByFlow(s);
  69.                         }
  71.                         #endregion
  72.                         break;
  73.                 }
  75.                 await Task.Delay(500);
  76.             };
  78.             #endregion
  79.         }
  80.         catch (Exception ex)
  81.         {
  82.             Panda.Framework.Helper.ConsoleHelper.WriteInfoLine($"SensorThread error,{ ex.Message }");
  83.         }
  84.         finally
  85.         {
  86.             Panda.Framework.Helper.ConsoleHelper.WriteInfoLine($"传感器数据下次采集时间，{DateTime.Now.AddMilliseconds(GloalConfigs.SleepRuningSensor).ToString("yyyy-MM-dd HH:mm:ss")}");
  87.             await Task.Delay(GloalConfigs.SleepRuningSensor);
  88.         }
  90.         #endregion
  91.     }
  93.     #endregion
  94. }