异步等待不起作用定时器

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准备好“转换”整个应用程序来支持它。