異步等待不起作用定時器

Question

我有一個存在監視器類用於檢測用戶活動/非活動狀態。這個類在它的啓動方法，要求在應用程序啓動一個定時器：

public class PresenceMonitor 
{ 
    private volatile bool _running; 
    private Timer _timer; 
    private readonly TimeSpan _presenceCheckInterval = TimeSpan.FromMinutes(1); 


    public PresenceMonitor() 
    { 
    } 

    public void Start() 
    { 
     // Start the timer 
     _timer = new Timer(_ => 
     { 
      Check(); 
     }, null, TimeSpan.Zero, _presenceCheckInterval); 
    } 

    private void Check() 
    { 
     if (_running) 
     { 
      return; 
     } 

     _running = true; 

     // Dowork 
    } 
} 

「檢查」的方法是每隔一分鐘後被解僱。這一段代碼工作正常，但現在我的「做工作」的方法已成爲異步等待，所以我不得不這種存在監控類更改爲這樣的事情：

public class PresenceMonitor 
{ 
    private volatile bool _running; 
    private Timer _timer; 
    private readonly TimeSpan _presenceCheckInterval = TimeSpan.FromMinutes(1); 


    public PresenceMonitor() 
    { 
    } 

    public void Start() 
    { 
     // Start the timer 
     var timer = new System.Threading.Timer(async (e) => 
     { 
      await CheckAsync(); 
     }, null, TimeSpan.Zero, _presenceCheckInterval); 
    } 

    private async Task CheckAsync() 
    { 
     if (_running) 
     { 
      return; 
     } 

     _running = true; 

     // await DoworkAsync 
    } 
} 

不幸「CheckAsync」方法現在被解僱了一次而不是每分鐘。你能告訴我我在做什麼錯在這裏調用async等待定期後？

有沒有正確的方法來做同樣的事情？

Answer 1

您可以考慮創建一個事件和處理程序來處理計時器滴答，然後調用您的支票。

public class PresenceMonitor { 
    private volatile bool _running; 
    private Timer timer; 
    private readonly TimeSpan _presenceCheckInterval = TimeSpan.FromMinutes(1); 

    public PresenceMonitor() { 
     Tick += OnTick; 
    } 

    public void Start() { 
     if (_running) { 
      return; //already running 
     } 
     // Start the timer 
     timer = new System.Threading.Timer(_ => { 
      Tick(this, EventArgs.Empty);//rasie event 
     }, null, TimeSpan.Zero, _presenceCheckInterval); 
    } 

    private event EventHandler Tick = delegate { }; 
    private async void OnTick(object sender, EventArgs args) { 
     if (_running) { 
      return; 
     } 
     _running = true; 
     await DoworkAsync(); 
    } 

    private Task DoworkAsync() { 
     //... 
    } 
} 

Answer 2

如果我理解正確，您的要求，您可以擺脫計時器和使用異步循環。
但你需要做Start方法異步太

public class PresenceMonitor 
{ 
    private volatile bool _running; // possible not needed "volatile" anymore 
    private readonly int _presenceCheckInterval = 60000; // Milliseconds 

    public PresenceMonitor() 
    { 
    } 

    public async Task Start() 
    { 
     while (true) // may be use some "exit" logic 
     { 
      await CheckAsync(); 
      await Task.Delay(_presenceCheckInterval) 
     } 
    } 

    private async Task CheckAsync() 
    { 
     if (_running) 
     { 
      return; 
     } 

     _running = true; 

     // await DoworkAsync 
    } 
} 

然後你就可以開始監測

var monitor = new PresenceMonitor(); 
await monitor.Start(); 

你甚至可以開始監測同步方式

var monitor = new PresenceMonitor(); 
monitor.Start(); // Will start monitoring 

但上述做法是「危險的「順便說一下，CheckAsync方法中拋出的任何異常都不會被傳播。當你開始使用async-await準備好「轉換」整個應用程序來支持它。