Параллельная обработка каталога

Question

Я работаю над мониторингом файлового каталога, в котором я должен искать конкретный каталог «D: \ Watch», и если есть какие-либо новые обнаружения файлов, я должен обработать его и показать содержимое. Я использовал FileSystemWatcher, но мое требование - проверять каталог на каждые 1 минуту. Вот почему я пропускаю FileSystemWatcher и делаю службу Windows, которая назначается через каждые 1 минуту и ​​читает каталог для обработки новых файлов.

Но мое требование состоит в том, чтобы читать файлы в Parallel и показывать содержимое после обработки файла и не нужно ждать, пока другие файлы будут обработаны. Мне также нужно обработать исключение, если какой-либо из файлов не имеет надлежащего содержимого.

Как я могу достичь этой задачи с помощью вышеуказанных требований параллельно. Я использую C# .net. Спасибо

Answer 1

Если я правильно понял вас, этот код должен работать на вас.

var filePaths = Directory.EnumerateFiles(@"c:\mydir"); 
    Parallel.ForEach(filePaths, ProcessFile); 

Вот ваша логика обработки

private void ProcessFile(string filePath) 
    { 
     //do what you have to do here. Proper exception handling is needed in this method  
    }