问题描述
|
我正在构建Windows服务，该服务将基于数据库中的计划审核用户。该服务每十分钟检查一次数据库以进行计划的审核。一旦审计开始，它将在数据库表中标记一个开始时间，因此如果花费的时间超过十分钟，它将不会再次开始。
我的问题是，下面的代码是否可以接受我的工作，并且每隔10分钟我应该使用多线程吗？如果是，我将如何完成此工作？
我的示例代码：
protected override void OnStart(string[] args)
{
var aTimer = new Timer(600000);
aTimer.Elapsed += ATimerElapsed;
aTimer.Interval = 600000;
aTimer.Enabled = true;
GC.KeepAlive(aTimer);
}
private static void ATimerElapsed(object sender,ElapsedEventArgs e)
{
try
{
Worker.ProcessScheduledAudits();
}
catch (Exception ex)
{
EventLog.WriteEntry(\"Application\",ex.Message,EventLogEntryType.Error);
}
}
解决方法
System.Threading.Timer将使用Threadpool中的线程来运行Elapsed处理程序。因此，仅通过使用计时器，您就已经在使用多线程。实际上，所有计时器都使用某种类型的后台线程。它们只是在多线程的方式上有所不同，以便针对预期用途进行最有意义的操作。
如果您需要每十分钟运行一次，但又要确保两个处理程序永远不会同时运行，请尝试在Elapsed方法中设置\“ CurrentlyRunning \”标志，并在进行任何繁重的操作之前进行检查。
protected override void OnStart(string[] args)
{
var aTimer = new Timer(600000);
aTimer.Elapsed += ATimerElapsed;
aTimer.Interval = 600000;
aTimer.Enabled = true;
GC.KeepAlive(aTimer);
}
private static currentlyRunning;
private static void ATimerElapsed(object sender,ElapsedEventArgs e)
{
if(currentlyRunning) return;
currentlyRunning = true;
try
{
Worker.ProcessScheduledAudits();
}
catch (Exception ex)
{
EventLog.WriteEntry(\"Application\",ex.Message,EventLogEntryType.Error);
}
currentlyRunning = false;
}
SynchronizingObject