快捷導(dǎo)航

C#中定時(shí)任務(wù)被阻塞問(wèn)題的解決方法

更新時(shí)間：2021年11月12日 14:42:48 作者：JerryMouseLi

這篇文章主要給大家介紹了關(guān)于C#中定時(shí)任務(wù)被阻塞問(wèn)題的解決方法,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家學(xué)習(xí)或者使用c#具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

1.摘要

本文會(huì)介紹一個(gè)C#中最簡(jiǎn)單定時(shí)任務(wù)的使用方法，以及會(huì)遇到的定時(shí)任務(wù)被阻塞現(xiàn)象，從筆者理解的角度分析原因。以及提供解決方案。

2.C#中定時(shí)任務(wù)的最簡(jiǎn)方法

  protected internal void PollClient()
  {
      int i=0;
      Timer t = new Timer(p => {
          i++;
          if (deviceContextList.Count > 0)
          {
              var deviceContext=GetDeviceContext("123456789");
                  SendMessage(messageList[i%7],deviceContext.tcpSession.writerContext);
              logger.Info("客戶(hù)端數(shù)量："+ deviceContextList.Count);        
          }
          else 
          {
              logger.Info("客戶(hù)端數(shù)量為0");
              Console.WriteLine("客戶(hù)端數(shù)量為0");
          }              
      }, null, 0, 1000) ;           
  }

上面的timer方法提供于微軟System.Threading命名空間。System.Threading.Timer 是由線(xiàn)程池調(diào)用的。所有的Timer對(duì)象只使用了一個(gè)線(xiàn)程來(lái)管理。這個(gè)線(xiàn)程知道下一個(gè)回調(diào)對(duì)象在什么時(shí)候到期。下一個(gè)回調(diào)對(duì)象到期時(shí)，線(xiàn)程就會(huì)喚醒，在內(nèi)部調(diào)用ThreadPool 的 QueueUserWorkItem，將一個(gè)工作項(xiàng)添加到線(xiàn)程池隊(duì)列中，使你的回調(diào)方法得到調(diào)用。此方法有多個(gè)重載，具體讀者可以自行去看。

Timer(TimerCallback callback, object state, int dueTime, int period)

第一個(gè)參數(shù)callback是回調(diào)方法，第二個(gè)參數(shù)state可以傳參給回調(diào)方法的參數(shù)，第三個(gè)參數(shù)dueTime是第一次執(zhí)行回調(diào)函數(shù)的延時(shí)時(shí)間，單位毫秒，第四個(gè)參數(shù)period是調(diào)用回調(diào)函數(shù)的時(shí)間間隔。使用起來(lái)是不是特別方便，把你需要執(zhí)行的定時(shí)任務(wù)放在回調(diào)方法中，可獨(dú)立寫(xiě)成方法，也可像上面一樣寫(xiě)成匿名方法的形式。

3.定時(shí)任務(wù)阻塞現(xiàn)象

當(dāng)上述任務(wù)被執(zhí)行了幾千次以后，定時(shí)任務(wù)會(huì)阻塞，不再執(zhí)行，也不再打印日志。并且上面的寫(xiě)法有缺陷，。如果回調(diào)方法的執(zhí)行時(shí)間很長(zhǎng)，計(jì)時(shí)器可能（在上個(gè)回調(diào)還沒(méi)有完成的時(shí)候）再次觸發(fā)。這可能造成多個(gè)線(xiàn)程池線(xiàn)程同時(shí)執(zhí)行你的回調(diào)方法。并且線(xiàn)程切換也會(huì)造成諸多損耗時(shí)間。

4.阻塞現(xiàn)象原因分析

上面的方法中使用局部變量來(lái)創(chuàng)建指向一個(gè)線(xiàn)程定時(shí)器。因?yàn)榫植孔兞繒?huì)被GC回收，導(dǎo)致定時(shí)器失效。
具體改進(jìn)如下：

static int i=0;
static Timer _timer = null;
        protected  void PollClient()
        {
             _timer = new Timer(TimerCallback, null, 1000, Timeout.Infinite) ;           
        }
    private void TimerCallback(object state)
    {
            try
            {
                i++;
              
                if (deviceContextList.Count > 0)
                {
                    var deviceContext = GetDeviceContext("123456789");
                    SendMessage(messageList[i % 7], deviceContext.tcpSession.writerContext);
                    logger.Info("客戶(hù)端數(shù)量：" + deviceContextList.Count + "循環(huán)次數(shù)：" + i);

                }
                else
                {
                    logger.Info("客戶(hù)端數(shù)量為0" + "循環(huán)次數(shù)：" + i);
                    Console.WriteLine("客戶(hù)端數(shù)量為0" + "循環(huán)次數(shù)：" + i);
                }
            }
            catch (Exception e)
            {
                logger.Error("定時(shí)測(cè)試下發(fā)報(bào)文異常：" + e);
            }
            finally
            {
                _timer.Change( 1000, Timeout.Infinite);
            }
        }

將定時(shí)器與計(jì)數(shù)變量設(shè)置為static是為了定時(shí)器不被GC回收。定時(shí)任務(wù)執(zhí)行完成之后再設(shè)置下次調(diào)用時(shí)間間隔是為了該任務(wù)不過(guò)多占用線(xiàn)程池中的線(xiàn)程，節(jié)省線(xiàn)程切換時(shí)間等。