解決一個C#中定時任務(wù)被阻塞問題

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

2、C#中定時任務(wù)的最簡方法

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("客戶端數(shù)量："+?deviceContextList.Count);????????
????????}
????????else?
????????{
????????????logger.Info("客戶端數(shù)量為0");
????????????Console.WriteLine("客戶端數(shù)量為0");
????????}??????????????
????},?null,?0,?1000)?;???????????
}

上面的timer方法提供于微軟System.Threading命名空間。System.Threading.Timer 是由線程池調(diào)用的。所有的Timer對象只使用了一個線程來管理。這個線程知道下一個回調(diào)對象在什么時候到期。

下一個回調(diào)對象到期時，線程就會喚醒，在內(nèi)部調(diào)用ThreadPool 的 QueueUserWorkItem，將一個工作項添加到線程池隊列中，使你的回調(diào)方法得到調(diào)用。此方法有多個重載，具體讀者可以自行去看。

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

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

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

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

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

上面的方法中使用局部變量來創(chuàng)建指向一個線程定時器。因為局部變量會被GC回收，導(dǎo)致定時器失效。具體改進如下：

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("客戶端數(shù)量："?+?deviceContextList.Count?+?"循環(huán)次數(shù)："?+?i);

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

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

5、問題解決

可以看到任務(wù)已經(jīng)被執(zhí)行了86665次，優(yōu)化后不再被GC回收。