如何防止 System.Timers.Timer 在线程池上排队执行？

Question

标准 System.Timers.Timer 行为存在问题。计时器以一定的时间间隔引发 Elapsed 事件。但是当 Elapsed 事件处理程序内的执行时间超过计时器间隔时，线程池开始排队事件处理。在我的情况下这是一个问题。这是因为我使用 Elapsed 事件处理程序从数据库中获取一些数据并对其进行处理，最后将结果保存回数据库。但是数据处理应该只提供一次。那么，有没有办法防止对 System.Timers.Timer 的 elapse 事件进行排队。

作为这个问题的说明，你可以考虑下一个测试程序：

public class EntryPoint
{

    private static void TimeProc(object state, ElapsedEventArgs e)
    {
        Console.WriteLine("Current time {0} on the thread {1}", DateTime.Now, Thread.CurrentThread.ManagedThreadId);
        Thread.Sleep(20000);
    }

    static void Main(string[] args)
    {
        Console.WriteLine("Press <Enter> for finishing\n\n");
        ThreadPool.SetMaxThreads(10, 10);
        System.Timers.Timer MyTimer = new System.Timers.Timer(1000);
        MyTimer.Elapsed += new ElapsedEventHandler(TimeProc);
        MyTimer.Start();
        Console.ReadLine();
        MyTimer.Stop();
    }
}

可能的输出如下：

Current time 03.02.2011 0:00:09 on the thread 4
Current time 03.02.2011 0:00:10 on the thread 5
Current time 03.02.2011 0:00:12 on the thread 6
Current time 03.02.2011 0:00:13 on the thread 7
Current time 03.02.2011 0:00:14 on the thread 8
Current time 03.02.2011 0:00:15 on the thread 9
Current time 03.02.2011 0:00:16 on the thread 10
Current time 03.02.2011 0:00:17 on the thread 11
Current time 03.02.2011 0:00:18 on the thread 12
Current time 03.02.2011 0:00:19 on the thread 13
Current time 03.02.2011 0:00:30 on the thread 4
Current time 03.02.2011 0:00:30 on the thread 5

可能的解决方案：

1) 灵感来自：C# Timer vs Thread in Service

关于上述示例，这里有一个类似的代码：

    public class EntryPoint
    {
        private static System.Timers.Timer MyTimer;
        private static void TimeProc(object state, ElapsedEventArgs e)
        {
            Console.WriteLine("Current time {0} on the thread {1}", DateTime.Now, Thread.CurrentThread.ManagedThreadId);
            Thread.Sleep(20000);
            MyTimer.Enabled = true;
        }

        static void Main(string[] args)
        {
            Console.WriteLine("Press <Enter> for finishing\n\n");
            ThreadPool.SetMaxThreads(10, 10);
            MyTimer = new System.Timers.Timer(1000);
            MyTimer.AutoReset = false;

            MyTimer.Elapsed += new ElapsedEventHandler(TimeProc);
            MyTimer.Enabled = true;
            Console.ReadLine();

        }
    }

2) 第二种方式是关于 SynchronizingObject，但它仅对 Windows 窗体应用程序有价值或需要额外开发代码来实现将实现 ISynchronizeInvoke 接口的对象。有关此方式的更多信息，您可以找到here

所以，现在我更喜欢第一个解决方案。

Answer 1

在这种情况下，我通常会在 Elapsed 处理程序的开始处停止计时器并在结束时重新启动它。这样，您一次只处理一个刻度。

更新：

根据 MSDN 链接，我认为他们的意思是您可以设置自己的标志（但仍然有刻度），但也应采取线程安全措施。

Answer 2

我想说简单地停止它，然后在像这样长时间执行后启动它。

tmr.Stop();
//Your lengthy execution code goes here
tmr.Start();

Answer 3

您看到的行为是设计使然。要么在计时器上设置SynchronizingObject，要么使用另一个不会在多个线程上计时的计时器（例如System.Threading.Timer）。

Answer 4

我只是创建一个静态标志变量。这样我的计时器继续运行，但如果该方法在下一个计时器周期之前尚未完成，则代码将被简单地绕过。

在用于计时器的方法中，测试事件是否正在进行中。

Timer_Method_Called()
{
  if (eventInProgress == 0)
  {
     // flag event as in progress
     eventInProcess == 1;

     // perform code....

     // after code is complete, allow the method to execute
     eventInProgress == 0;
  }
}

Answer 5

由于没有一个答案是线程安全的，所以让我提出一个：

void oneHundredMS_Elapsed(object sender, System.Timers.ElapsedEventArgs e) {

  if (setTimerBodyRunning()) { //only proceed to body if it is not already processing; setTimerBodyRunning must be thread-safe
    // here you do your long running operation
    setTimerBodyFinished();
  }
}

如您所见，计时器处理程序首先检查它是否尚未运行，如果返回 false，则仅继续执行主体。如果返回 true，则处理程序会快速返回，并且滴答声不会排队（他们本来可以使用简单的 lock 语句）。下面是 setTimerBodyRunning 和 setTimerBodyFinished 的定义：

private bool setTimerBodyRunning() {
        bool retVal = false;
        lock (timerBodyRunning) { //timerBodyRunning is type object and it holds a bool.  
            //The reason it is object and not bool is so it can be locked on to ensure thread safety
            if (!((bool)timerBodyRunning)) {
                timerBodyRunning = true;
                retVal = true;
            }
        }
        return retVal;
    }

private void setTimerBodyFinished() {
    lock (timerBodyRunning) {
        timerBodyRunning = false;
    }
}

以下是初始化和启动计时器的方法：

object timerBodyRunning = new object();
timerBodyRunning = false;
System.Timers.Timer timerFrequency100MS = new System.Timers.Timer();
timerFrequency100MS.Interval = FREQUENCY_MS; //it will fire every 100 milliseconds
timerFrequency100MS.Elapsed += new System.Timers.ElapsedEventHandler(oneHundredMS_Elapsed);
timerFrequency100MS.Start();