本人使用服务调用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的意图是为了定期扫描处理文件,不是为了并发提高速度(我们本来就不想用并发,否则是在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加上上一次回调方法执行所需时间。