如果前一个线程仍然繁忙，如何让计时器跳过刻度

Question

我创建了一个 Windows 服务，该服务应该每 60 秒检查数据库中的某个表是否有新行。对于添加的每个新行，我都需要在服务器上进行一些繁重的处理，有时可能需要 60 秒以上的时间。

我在服务中创建了一个 Timer 对象，该对象每 60 秒计时一次并调用所需的方法。
由于我不希望此计时器在处理找到的新行时计时，因此我将该方法包装在 lock { } 块中，因此其他线程无法访问该方法。

它看起来像这样：

Timer serviceTimer = new Timer();
serviceTimer.Interval = 60;
serviceTimer.Elapsed += new ElapsedEventHandler(serviceTimer_Elapsed);
serviceTimer.Start();

void serviceTimer_Elapsed(object sender, ElapsedEventArgs e)
{
    lock (this)
    {
        // do some heavy processing...
    }
}

现在，我想知道 -
如果我的计时器滴答作响，并在数据库上发现很多新行，并且现在处理将花费超过 60 秒，则下一个滴答不会执行任何处理，直到前一个滴答完成。这就是我想要的效果。

但现在，serviceTimer_Elapsed 方法是在第一次处理完成后立即关闭，还是等待计时器再次计时。

我想要发生的是 - 如果处理需要超过 60 秒，那么计时器会注意到线程被锁定，并再等待 60 秒再次检查，这样我就永远不会陷入有线程队列的情况等待上一篇完成。

我怎样才能达到这个结果？
这样做的最佳实践是什么？

谢谢！

Answer 1

您可能会尝试在处理过程中禁用计时器，例如

// Just in case someone wants to inherit your class and lock it as well ...
private static object _padlock = new object();
try
{
  serviceTimer.Stop(); 

  lock (_padlock)
    { 
        // do some heavy processing... 
    } 
}
finally
{
  serviceTimer.Start(); 
}

编辑：OP没有指定重入是否仅由计时器引起，或者服务是否是多线程的。假设是后者，但如果是前者，那么如果计时器停止（自动重置或手动），则锁定应该是不必要的

Answer 2

在这种情况下你不需要锁。在启动之前设置timer.AutoReset=false。
处理完成后，重新启动处理程序中的计时器。这将确保计时器在每个任务后 60 秒触发。

Answer 3

其他答案的类似变体，允许计时器继续滴答作响，并且仅在获得锁定时才执行工作，而不是停止计时器。

将其放入已用事件处理程序中：

if (Monitor.TryEnter(locker)
{
    try
    {
        // Do your work here.
    }
    finally
    {
        Monitor.Exit(locker);
    }
}

Answer 4

快速检查一下服务是否正在运行。如果它正在运行，它将跳过此事件并等待下一个事件触发。

Timer serviceTimer = new Timer();
serviceTimer.Interval = 60;
serviceTimer.Elapsed += new ElapsedEventHandler(serviceTimer_Elapsed);
serviceTimer.Start();
bool isRunning = false;
void serviceTimer_Elapsed(object sender, ElapsedEventArgs e)
{
    lock (this)
    {
        if(isRunning)
            return;
        isRunning = true;
    }
    try
    {
    // do some heavy processing...
    }
    finally
    {
        isRunning = false;
    }
}

Answer 5

我建议您在处理时不要让计时器滴答作响。

将计时器自动重置设置为 false。并从最后开始。这是您可能感兴趣的完整答案
需要：从数据库中的作业队列执行作业的 Windows 服务；需要：示例代码

Answer 6

其他选项可能是使用 BackGroundWorker 类或 TheadPool.QueueUserWorkItem。

后台工作人员可以轻松地为您提供选项检查当前处理仍在发生并一次处理 1 项。 ThreadPool 将使您能够在每次更新（如果需要）时继续将项目排队到后台线程。

根据您的描述，我假设您正在检查数据库队列中的项目。在这种情况下，我将使用 ThreadPool 将工作推送到后台，而不是减慢/停止检查机制。

对于服务，我真的建议您考虑使用线程池方法。这样，您可以使用计时器每 60 秒检查一次新项目，然后将它们排队，让 .Net 计算出要分配给每个项目的量，然后继续将项目推入队列。

例如：如果您仅使用计时器并且有 5 个新行，则总共需要 65 秒的处理时间。使用线程池方法，这将在 65 秒内完成，并有 5 个后台工作项。使用计时器方法，这将需要 4 分钟以上（每行之间等待的分钟），而且这可能会导致其他正在排队的工作积压。

以下是应如何完成此操作的示例：

Timer serviceTimer = new Timer();
    void startTimer()
    {
        serviceTimer.Interval = 60;
        serviceTimer.Elapsed += new ElapsedEventHandler(serviceTimer_Elapsed);
        serviceTimer.AutoReset = false;
        serviceTimer.Start();
    }
    void serviceTimer_Elapsed(object sender, ElapsedEventArgs e)
    {
        try
        {
            // Get your rows of queued work requests

            // Now Push Each Row to Background Thread Processing
            foreach (Row aRow in RowsOfRequests)
            {
                ThreadPool.QueueUserWorkItem(
                    new WaitCallback(longWorkingCode), 
                    aRow);
            }
        }
        finally
        {
            // Wait Another 60 Seconds and check again
            serviceTimer.Stop();
        }
    }

    void longWorkingCode(object workObject)
    {
        Row workRow = workObject as Row;
        if (workRow == null)
            return;

        // Do your Long work here on workRow
    }

Answer 7

有一种非常巧妙的方法可以通过响应式扩展来解决这个问题。这是代码，您可以在这里阅读更完整的解释： http://www.zerobugbuild.com/? p=259

public static IDisposable ScheduleRecurringAction(
    this IScheduler scheduler,
    TimeSpan interval,
    Action action)
{
    return scheduler.Schedule(
        interval, scheduleNext =>
    {
        action();
        scheduleNext(interval);
    });
}

你可以这样使用它：

TimeSpan interval = TimeSpan.FromSeconds(5);
Action work = () => Console.WriteLine("Doing some work...");

var schedule = Scheduler.Default.ScheduleRecurringAction(interval, work);          

Console.WriteLine("Press return to stop.");
Console.ReadLine();
schedule.Dispose();

Answer 8

另一种可能性是这样的：

void serviceTimer_Elapsed(object sender, ElapsedEventArgs e)
{   
    if (System.Threading.Monitor.IsLocked(yourLockingObject))
       return;
    else
       lock (yourLockingObject)
       // your logic  
           ;
}