使用System.Threading.Timer产生并发的原因和避免并发的小技巧

时间:2022-03-03 20:40:34

    本人使用服务调用Timer处理手机端和Pda端上传至服务器的大量文件,有时会报拒绝访问文件甚至服务崩溃的情况。因为Timer到期后,线程池线程会执行回调方法,如果回调方法执行时间太长,Timer会再次(在上次执行回调方法结束前)调用线程池新线程执行回调方法。此时,如果回调方法访问共享资源,我们没有加同步锁,就会造成数据的不一致、拒绝访问、多次处理相同资源甚至程序崩溃的错误。如本人的程序,思路是处理完文件A之后将其挪到其它备份查阅目录,如果第一个线程处理A文件占用了很长时间,另一个线程再次处理A文件,此时第一个线程是不允许挪走A文件的,第二个正在读取,有可能第三个,第四个甚至更多线程访问A文件。这样会造成A文件多次重复处理,向数据库多次插入同样的记录,并且可能锁死A文件。演示代码如下:

 nmespace TimerExample
{
    class Program
    {
       static Timer _timer;
        static void Main(string[] args)
        {
            //实例化timer,5秒之后执行,间隔20秒
            _timer = new Timer(DealFile, null, 5 * 1000, 20 * 1000);
            Console.ReadLine();
        }

      // 处理文件的方法会很占用时间
     pivate static void DealFile(object state)
        {
            //通过比对随机数查看执行情况
            Random random = new Random();
            int tempRandomData= random.Next();
            Console.WriteLine("处理文件开始...," + tempRandomData);
            //模拟处理文件的时间25秒
            Thread.Sleep(25 * 1000);
            Console.WriteLine("处理文件结束...,"+tempRandomData);


         }
  }
}

执行结果如下:

处理文件开始...,217262014
处理文件开始...,1304498158
处理文件结束...,217262014
处理文件开始...,918462592
处理文件结束...,1304498158

由上可知,当第一次执行没有结束时,Timer再次调用了回调方法DealFile,产生了处理文件开始(绿色部分)的输出

  果我们使用Timer的意图是为了定期扫描处理文件,不是为了并发提高速度(我们本来就不想用并发,否则是在Timer回调方法内使用多线程技术,而不会因为回调方法执行时间太长使得Timer自己产生多个线程)。我们可以在首次事例化Timer时,peroid传入System.Threading.Timeout.Infinite,表示只执行一次timer,然后在回调方法内调用Change方法,timer.Change(interval,System.Threading.Timeout.Infinite),如此则是每次处理完回调方法之后才会再次在Interval时间之后执行回调方法,演示代码如下

 namespace TimerExample
{
    class Program
    {
       static Timer _timer;
        static void Main(string[] args)
        {
            //实例化timer,5秒之后执行,间隔20秒
            _timer = new Timer(DealFile, null, 5 * 1000, Timeout.Infinite);//20 * 1000);
            Console.ReadLine();
        }
        private static void DealFile(object state)
        {
            //通过比对随机数查看执行情况
            Random random = new Random();
            int tempRandomData= random.Next();
            Console.WriteLine("处理文件开始...," + tempRandomData);
            //模拟处理文件的时间25秒
            Thread.Sleep(25 * 1000);
            Console.WriteLine("处理文件结束...,"+tempRandomData);
            _timer.Change(20 * 1000, Timeout.Infinite);
        }
    }
}

 执行结果:

处理文件开始...,40380869
处理文件结束...,40380869
处理文件开始...,1750026338
处理文件结束...,1750026338

由上执行可知,Timer的调用是在上次回调方法执行结束之后,才间隔interval(20秒)再次调用回调方法的

当然,此时执行回调方法的时间间隔是interval加上上一次回调方法执行所需时间。