Wie füge ich einer verzögerten Aufgabe Zeit hinzu?

Question

Ich habe einen Prozess, wo ich FileSystemWatcher spin up, um das Dateisystem für eingehende Dateien zu sehen.

Ich habe eine Verzögerung mit Task.Delay eingerichtet, die den FSW abbricht, entweder wenn das Stornierungs-Token gesetzt ist oder nach Ablauf der Zeit (zum Beispiel 10 Minuten).

Aber ich würde es gerne so konfigurieren, dass ich jedes Mal, wenn eine neue Datei erscheint, zusätzliche Verzögerung hinzufügen kann. Also effektiv eine Art gleitende Ablaufverzögerung.

Answer 1

Sie könnten Ihre Verzögerungsmethode leicht ändern, um die Ausführungszeit verschieben zu können.

Ich habe ein kleines Beispiel für Sie erstellt.

Anschließend können Sie machen nur eine "verzögerte dispose" des FileSystemWatcher auf einfache Weise:

CancellationTokenSource cts = new CancellationTokenSource(); 
await watcher.DisposeDelayed(TimeSpan.FromSeconds(10), cts.Token); 

Ich habe eine Erweiterungsmethode für die FileSystemWatcher:

static class Utilities 
{ 
    public static async Task DisposeDelayed(this FileSystemWatcher watcher, TimeSpan inactivePeriod, CancellationToken ct) 
    { 
     DateTime disposalTime = DateTime.Now + inactivePeriod; 
     FileSystemEventHandler postponeTrigger = (s, e) => disposalTime = DateTime.Now + inactivePeriod; 
     watcher.Created += postponeTrigger; 
     watcher.Changed += postponeTrigger; 
     // add here other event handlers you need to postpone the disposal 

     try 
     { 
      await RunAtTimePoint(() => disposalTime, ct, watcher.Dispose).ConfigureAwait(false); 
     } 
     finally 
     { 
      // don't forget to unsubscribe from each event 
      watcher.Created -= postponeTrigger; 
      watcher.Changed -= postponeTrigger; 
     } 
    } 

    // You can also use this method for other tasks if you need 
    public static async Task RunAtTimePoint(Func<DateTime> execTimeProvider, CancellationToken token, Action action) 
    { 
     int delayTime; 
     do 
     { 
      // first, calculate the time left until the execution 
      DateTime execTime = execTimeProvider(); 
      TimeSpan timeLeft = execTime - DateTime.Now; 

      // we delay in 1000 ms chunks; 
      // but if the delay time is less, we need to handle that 
      delayTime = (int)Math.Min(1000d, timeLeft.TotalMilliseconds); 
      if (delayTime > 0) 
      { 
       // don't forget the ConfigureAwait call: 
       // we don't need the context switch each time 
       await Task.Delay(delayTime, token).ConfigureAwait(false); 
      } 
     } 
     while (delayTime > 0 && !token.IsCancellationRequested); 

     if (!token.IsCancellationRequested) 
     { 
      action(); 
     } 
    } 
}