FileSystemWatcher and Queues with Parallel Execution

Sometime we need a program to watch over particular Directory and then based on the Input,we need to perform some other task in parallel.

Here, I am providing a part of program(a window service)that uses FileSystemWacther to monitor a Directory and then based on Input perform some other task parallely.

Note: You should learn FileSystemWatcher before going through this Post.

OnStartis the Window Service method .You can use Console pgm or TaskScheduler also.

1. protected override void OnStart(string[] args)
2. {
4. current_directory = Path.GetDirectoryName(Assembly.GetExecutingAssembly().Location);
6. try
7. {
8. strDir = ConfigurationManager.AppSettings["Directory"];
9. fileMask = ConfigurationManager.AppSettings["FileMask"];
10. strBatfile = ConfigurationManager.AppSettings["Batch"];
11. strlog = ConfigurationManager.AppSettings["Log"];
13. Task.Factory.StartNew(QueueHandler);
15. var fsw = new FileSystemWatcher();
16. fsw.Created += (o, e) =>
17. {
18. // add a file to the queue
19. filenames.Enqueue(e.FullPath);
21. };
23. fsw.Path = strDir + "\\";
24. fsw.NotifyFilter = NotifyFilters.LastAccess | NotifyFilters.LastWrite
25. | NotifyFilters.FileName | NotifyFilters.DirectoryName;
26. fsw.Filter = fileMask;
28. fsw.EnableRaisingEvents = true;
29. fsw.Deleted += new FileSystemEventHandler(OnDeleated);
30. fsw.Renamed += new RenamedEventHandler(OnRenamed);
33. fsw.EnableRaisingEvents = true;
34. }
35. catch (Exception exception)
36. {
37. CustomException.Write(CustomException.CreateExceptionString(exception.ToString()));
38. }
40. }