这是使用System.Threading.Timer来运行预定的async/await方法的正确方法吗?

本文关键字：方法 await async System Threading 运行 Timer | 更新日期: 2023-09-27 18:17:39

我目前正在做一个项目，我想在后台执行一些定期更新，我想使用async/await为此目的使用System.Threading.Timer。我没能找到任何关于这个主题的文章。

下面的代码片段可以工作。我只是不确定使用异步方法返回void时，应该只用于事件处理程序，如按钮单击。下面的代码中是否有"违反"最佳实践的内容?

public class ScheduledCache
{
    private CancellationTokenSource _cancelSource = new CancellationTokenSource();
    private Request _request = new Request();
    private Timer _timer;
    public void Start()
    {
        _cancelSource = new CancellationTokenSource();
        _timer = new Timer(UpdateAsync, null, 2000, Timeout.Infinite);
    }
    public void Stop()
    {
        _cancelSource.Cancel();
    }
    public async void UpdateAsync(object state)
    {
        try
        {
            await Task.WhenAll(UpdateSomethingAsync(_cancelSource.Token), UpdateSomethingElseAsync(_cancelSource.Token));
        }
        catch (OperationCanceledException)
        {
            // Handle cancellation
        }
        catch (Exception exception)
        {
            // Handle exception
        }
        finally
        {
            if (_cancelSource.IsCancellationRequested)
                _timer = new Timer(UpdateAsync, null, 2000, Timeout.Infinite);
            else
                _timer = new Timer(UpdateAsync, null, Timeout.Infinite, Timeout.Infinite);
        }
    }
    private async Task UpdateSomethingAsync(CancellationToken cancellationToken)
    {
        await Task.Run(new Action(_request.UpdateSomething));
    }
    private async Task UpdateSomethingElseAsync(CancellationToken cancellationToken)
    {
        await Task.Run(new Action(_request.UpdateSomethingElse));
    }
}
public class Request
{
    public void UpdateSomething()
    {
        // Do some updates here
    }
    public void UpdateSomethingElse()
    {
        // Do some other updates here
    }
}

这是使用System.Threading.Timer来运行预定的async/await方法的正确方法吗?

我只是不确定使用异步方法返回void时，应该只用于事件处理程序，如按钮点击

嗯，您正在为Timer.Elapsed事件注册一个事件处理程序，因此以这种方式使用它是可以的。

一般来说，我会做一些不同的事情。首先，使用async over sync反模式，这是我要避免的。将Task.Run移动到调用堆栈中可能的最高位置。然后，如果您只调用一个单行异步方法，只需返回它而不是等待它，这样就可以保存异步状态机的生成。

您可以考虑的另一件事是，而不是使用Timer，您可以循环使用Task.Delay，它内部使用定时器，但向调用者公开Task。

大致如下所示:

public async Task StartAsync()
{
    _cancelSource = new CancellationTokenSource();
    await UpdateAsync(_cancelSource.Token);
}
public async Task UpdateAsync(CancellationToken cancellationToken)
{
    try
    {
         var updateSomething = Task.Run(() => _request.UpdateSomething()));
         var updateSomethingElse = Task.Run(() => _request.UpdateSomethingElse());
        await Task.WhenAll(updateSomething, updateSomethingElse);
    }
    catch (OperationCanceledException)
    {
        // Handle cancellation
    }
    catch (Exception exception)
    {
        // Handle exception
    }
    finally
    {
        if (_cancelSource.IsCancellationRequested)
            await Task.Delay(2000);
    }
}
相关文章：