C#中定時任務被阻塞問題的解決方法
1.摘要
本文會介紹一個C#中最簡單定時任務的使用方法,以及會遇到的定時任務被阻塞現(xiàn)象,從筆者理解的角度分析原因。以及提供解決方案。
2.C#中定時任務的最簡方法
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í)行的定時任務放在回調(diào)方法中,可獨立寫成方法,也可像上面一樣寫成匿名方法的形式。
3.定時任務阻塞現(xiàn)象
當上述任務被執(zhí)行了幾千次以后,定時任務會阻塞,不再執(zhí)行,也不再打印日志。并且上面的寫法有缺陷,。如果回調(diào)方法的執(zhí)行時間很長,計時器可能(在上個回調(diào)還沒有完成的時候)再次觸發(fā)。這可能造成多個線程池線程同時執(zhí)行你的回調(diào)方法。并且線程切換也會造成諸多損耗時間。
4.阻塞現(xiàn)象原因分析
上面的方法中使用局部變量來創(chuàng)建指向一個線程定時器。因為局部變量會被GC回收,導致定時器失效。
具體改進如下:
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ù)變量設置為static是為了定時器不被GC回收。定時任務執(zhí)行完成之后再設置下次調(diào)用時間間隔是為了該任務不過多占用線程池中的線程,節(jié)省線程切換時間等。
5.問題解決
可以看到任務已經(jīng)被執(zhí)行了86665次,優(yōu)化后不再被GC回收。

總結(jié)
到此這篇關于C#中定時任務被阻塞問題解決的文章就介紹到這了,更多相關C#定時任務被阻塞內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
C#實現(xiàn)輸入10個數(shù)存入到數(shù)組中并求max和min及平均數(shù)的方法示例
這篇文章主要介紹了C#實現(xiàn)輸入10個數(shù)存入到數(shù)組中并求max和min及平均數(shù)的方法,涉及C#簡單數(shù)據(jù)轉(zhuǎn)換與數(shù)值運算相關操作技巧,需要的朋友可以參考下2017-07-07
C#中調(diào)用VB中Inputbox類的實現(xiàn)方法
本文主要介紹在項目中引用Microsoft.VisualBasic,間接使用VB中的各種類庫的方法,或者自己創(chuàng)建函數(shù),調(diào)用自定義方法,以實現(xiàn)InputBox相關的功能。2016-05-05
C# 中的IComparable和IComparer的使用及區(qū)別
這篇文章主要介紹了C# 中的IComparable和IComparer的使用及區(qū)別,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2020-01-01
c# AcceptEx與完成端口(IOCP)結(jié)合的示例
這篇文章主要介紹了c# AcceptEx與完成端口(IOCP)結(jié)合的示例,幫助大家更好的理解和學習使用c#,感興趣的朋友可以了解下2021-03-03

