System.Timer.Timer重入问题解决方案

81 阅读 0 评论 54 点赞

我是靠谱客的博主炙热蛋挞，最近开发中收集的这篇文章主要介绍System.Timer.Timer重入问题解决方案，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

Timer的官方定义如下：

Timer 组件是基于服务器的计时器，它使您能够指定在应用程序中引发 Elapsed 事件的周期性间隔。然后可通过处理这个事件来提供常规处理。例如，假设您有一台关键性服务器，必须每周 7 天、每天 24 小时都保持运行。可以创建一个使用 Timer 的服务，以定期检查服务器并确保系统开启并在运行。如果系统不响应，则该服务可以尝试重新启动服务器或通知管理员。
基于服务器的 Timer 是为在多线程环境中用于辅助线程而设计的。服务器计时器可以在线程间移动来处理引发的 Elapsed 事件，这样就可以比 Windows 计时器更精确地按时引发事件

使用示例：

    //Timer不要声明成局部变量，否则会被GC回收
    private static System.Timers.Timer aTimer;

    public static void Main()
    {
        //实例化Timer类，设置间隔时间为10000毫秒； 
        aTimer = new System.Timers.Timer(10000);

        //注册计时器的事件
        aTimer.Elapsed += new ElapsedEventHandler(OnTimedEvent);

        //设置时间间隔为2秒（2000毫秒），覆盖构造函数设置的间隔
        aTimer.Interval = 2000;

        //设置是执行一次（false）还是一直执行(true)，默认为true
        aTimer.AutoReset = true;

        //开始计时
        aTimer.Enabled = true;

        Console.WriteLine("按任意键退出程序。");
        Console.ReadLine();
    }

    //指定Timer触发的事件
    private static void OnTimedEvent(object source, ElapsedEventArgs e)
    {
        Console.WriteLine("触发的事件发生在： {0}", e.SignalTime);
    }

当timer的前一个线程还没有执行完，到时间间隔timer会触发一个新的线程，被称为重入，但是有的业务场景需要上一个任务执行完毕才执行下一个这就需要避免重入发生。一般解决方案有两类：加锁；设置标识位。

第一种加锁解决：(适用于重入发生不频繁的时候，此时下一个事件等待锁释放)

Timer的定义不变，其他部分如下：

private static object _lock = new object(); //声明加锁变量

//将timer触发事件改造如下
private static void OnTimedEvent(object source, ElapsedEventArgs e)
{
     lock(_lock)
        {
            Console.WriteLine("触发的事件发生在：{0}", e.SignalTime);
        }   
}

第二种设置标识位：（此时会跳过下一个事件）

    private static int inTimer = 0; 
    /// <summary>
    /// System.Timers.Timer的回调方法
    /// </summary>
    /// <param name="sender"></param>
    /// <param name="args"></param>
    private static void TimersTimerHandler(object sender, EventArgs args)
    {
        int t = ++num;
        if (inTimer == 0)
        {
            inTimer = 1;
            Console.WriteLine(string.Format("线程{0}输出：{1}，       输出时间：{2}", t, outPut.ToString(), DateTime.Now));
            System.Threading.Thread.Sleep(2000);
            outPut++;
            Console.WriteLine(string.Format("线程{0}自增1后输出：{1}，输出时间：{2}", t, outPut.ToString(), DateTime.Now));
            inTimer = 0;
        }
    }

在多线程下给inTimer赋值不够安全，System.Threading.Interlocked.Exchange提供了一种轻量级的线程安全的给对象赋值的方法也是放弃执行。Interlocked.Exchange用法参考这里。

    private static int inTimer = 0; 
    /// <summary>
    /// System.Timers.Timer的回调方法
    /// </summary>
    /// <param name="sender"></param>
    /// <param name="args"></param>
    private static void TimersTimerHandler(object sender, EventArgs args)
    {
        int t = ++num;
        if (Interlocked.Exchange(ref inTimer, 1) == 0)
        {
            Console.WriteLine(string.Format("线程{0}输出：{1}，       输出时间：{2}", t, outPut.ToString(), DateTime.Now));
            System.Threading.Thread.Sleep(2000);
            outPut++;
            Console.WriteLine(string.Format("线程{0}自增1后输出：{1}，输出时间：{2}", t, outPut.ToString(), DateTime.Now));
            Interlocked.Exchange(ref inTimer, 0); 
        }
    }