异步操作突然停止？

Question

所以我创建了这个帮助方法来每 X 毫秒运行一个任务，尽管问题是任务在几次迭代后突然停止执行，我不明白为什么？没有给出任何理由。

辅助方法：

public static async Task RunPeriodically(TimeSpan timeSpan, Func<Task> task, CancellationToken cancellationToken)
{
    while (await new PeriodicTimer(timeSpan).WaitForNextTickAsync(cancellationToken))
    {
        await task();
    }
}

用法：

public class GameProcessor : IGameProcessor
{
    private readonly CancellationTokenSource _cts;

    public GameProcessor()
    {
        _cts = new CancellationTokenSource();
    }

    public async Task Boot()
    {
        await Task.Run(ProcessAsync);
    }
    
    public async Task ProcessAsync()
    {
        await TimerUtilities.RunPeriodically(TimeSpan.FromMilliseconds(500), _roomRepository.RunPeriodicCheckAsync, _cts.Token);
    }
}

然后在 Program.cs 中：

var gameProcessor = _serviceProvider.GetRequiredService<IGameProcessor>();
gameProcessor.Boot(); // not awaited

// ... rest of my flow

Answer 1

不要在每个周期创建新的 PeriodicTimer，而是使用单个实例：

public static async Task RunPeriodically(TimeSpan timeSpan, Func<Task> task, CancellationToken cancellationToken)
{
    var timer = new PeriodicTimer(timeSpan);
    while (await timer.WaitForNextTickAsync(cancellationToken))
    {
        await task();
    }
}