Ожидание системы для удаления файла

У меня возникла проблема с обновлением списка файлов после удаления файла. Когда я дал команду удалить файл, исключение было выбрано, потому что метод обновления попытался получить доступ к файлу, который должен был быть удален.

После некоторой мысли и отладки я пришел к выводу, что проблема в том, что для удаления файла требуется некоторое время. И я решаю это следующим образом:

//Deleting file
System.Threading.Thread.Sleep(2000);
//Refreshing list

и он работал нормально.

Мой вопрос

Есть ли более элегантный способ дождаться, когда система удалит файл, а затем продолжит с кодом...?

Ответ 1

Самый элегантный способ, которым я могу думать, - использовать FileSystemWatcher и подписаться на его событие Deleted.

Ответ 2

Это работает для меня:

public static void DeleteFile(String fileToDelete)
{
    var fi = new System.IO.FileInfo(fileToDelete);
    if (fi.Exists)
    {
        fi.Delete();
        fi.Refresh();
        while (fi.Exists)
        {    System.Threading.Thread.Sleep(100);
             fi.Refresh();
        }
    }
}

Я нахожу, что большую часть времени цикл while не будет введен.

Ответ 3

Легкий код для использования FileSystemWatcher, подпишитесь на его событие Deleted и подождите.

void DeleteFileAndWait(string filepath, int timeout = 30000)
{
    using (var fw = new FileSystemWatcher(Path.GetDirectoryName(filepath), Path.GetFileName(filepath)))
    using (var mre = new ManualResetEventSlim())
    {
        fw.EnableRaisingEvents = true;
        fw.Deleted += (object sender, FileSystemEventArgs e) =>
        {
            mre.Set();
        };
        File.Delete(filepath);
        mre.Wait(timeout);
    }
}

Ответ 4

Удаление каталога с помощью Directory.Delete, в частности перегрузка, которая принимает "рекурсивное" логическое значение на NTFS должно быть атомной операцией с точки зрения вашей программы. Вам не нужно самостоятельно переписывать себя.

Ответ 5

Вот код с помощью FileWatcher. Что мы хотим сделать, это

await Utils.DeleteDirectoryAsync("c:\temp\foo", recurse: true);

ниже реализует его

using System;
using System.IO;
using System.Reactive;
using System.Reactive.Linq;
using System.Reactive.Subjects;
using System.Threading.Tasks;

namespace Utils
{
    internal class FileWatcher : IDisposable
    {
        readonly FileSystemWatcher _Watcher;

        public Subject<FileSystemEventArgs> Changed = new Subject<FileSystemEventArgs>();

        public FileWatcher( string file )
        {
            // Create a new FileSystemWatcher and set its properties.
            _Watcher = new FileSystemWatcher
                       {
                           Path = Path.GetDirectoryName(file),
                           NotifyFilter = NotifyFilters.LastAccess | NotifyFilters.LastWrite
                                          | NotifyFilters.FileName | NotifyFilters.DirectoryName,
                           Filter =Path.GetFileName(file) 
                       };

            // Add event handlers.
            _Watcher.Changed += OnChanged;
            _Watcher.Created += OnChanged;
            _Watcher.Deleted += OnChanged;
            _Watcher.Renamed += OnChanged;

            // Begin watching.
            _Watcher.EnableRaisingEvents = true;
        }

        // Define the event handlers.
        private void OnChanged( object source, FileSystemEventArgs e )
        {
            Changed.OnNext(e);
        }


        public void Dispose()
        {
            _Watcher.Dispose();
        }
    }
}

и некоторые utils, которые используют вышеприведенное наблюдение.

public static class FileUtils
{
    public static IObservable<FileSystemEventArgs> ChangedObservable(string path)
    {
        if (path == null)
            return Observable.Never<FileSystemEventArgs>();

        return Observable.Using(() => new FileWatcher(path), watcher => watcher.Changed);
    }

    public static Task DeleteDirectoryAsync(string path, bool recurse)
    {
        var task = new TaskCompletionSource<Unit>();

        if (Directory.Exists(path))
        {
            ChangedObservable(path)
                .Where(f => f.ChangeType == WatcherChangeTypes.Deleted)
                .Take(1)
                .Subscribe(v => task.SetResult(Unit.Default));

            Directory.Delete(path, recurse);
        }
        else
        {
            task.SetResult(Unit.Default);
        }

        return task.Task;
    }
}

Ответ 6

Directory.Delete генерирует исключение при первой ошибке, с которой он сталкивается. Если вы хотите продолжить удаление как можно большего количества файлов и подкаталогов, вы не должны использовать Directory.Delete и должны написать собственное рекурсивное удаление с помощью блоков try/catch внутри циклов. Например, если вы захотите это сделать, это если вы пытаетесь очистить файлы temp и один из файлов был заблокирован.

Ответ 7

Я всегда использовал это:

System.GC.Collect();
System.GC.WaitForPendingFinalizers();

Смотрите here и здесь