【发布时间】:2016-01-20 17:55:51
【问题描述】:
我正在使用文件系统监视器来监视目录并在创建新文件时处理文件。我使用带有后台工作程序的计时器来防止并发问题和内存溢出。
这就是我所拥有的
//creating the watcher
watcher = new FileSystemWatcher();
watcher.Path = @"C:\Users\me\Desktop\watch";
watcher.Filter = "*.*";
watcher.Created += new FileSystemEventHandler(copied);
watcher.EnableRaisingEvents = true;
//hooking to creation event
void copied(object sender, FileSystemEventArgs e)
{
if (bwork.IsBusy == false)
{
bworkprocesslist.Add(e.FullPath);
}
else
{
bworkpendinglist.Add(e.FullPath);
}
}
//used timer to prevent concurrent access of resources and memory overflow
private void timer1_Tick(object sender, EventArgs e)
{
if (bwork.IsBusy==false)
{
bwork.RunWorkerAsync();
}
}
// Maintaining Lists and removed processed file from the main list
private void bwork_DoWork(object sender, DoWorkEventArgs e)
{
List<string> removedfiles = new List<string>();
foreach (string pfile in bworkprocesslist)
{
process(pfile) //Do processing of pfile
removedfiles.Add(pfile);
}
foreach (string x in removedfiles)
{
bworkprocesslist.Remove(x);
}
}
//Add files from pending list after background worker completion
void bwork_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
foreach (string s in bworkpendinglist)
{
bworkprocesslist.Add(s);
bworkpendinglist.Remove(s);
}
}
代码运行没有任何问题。但它有时会多次处理一个文件。我不知道错误发生在哪里。
【问题讨论】:
标签: c# .net timer concurrency filesystemwatcher