c# - 如何为 BackgroundService 的 ExecuteAsync 设置超时？

Question

我有一个名为 Worker 的 BackgroundService，我重写了 ExecuteAsync 方法以每 10 秒运行一次。有时，我跑的东西会持续很长时间。在这种情况下，我想终止正在运行的程序，然后重新运行它。我怎样才能做到这一点？

我的后台服务如下:

    public class Worker : BackgroundService {
        private readonly ITask task;
        private readonly IHostApplicationLifetime appLifeTime;

        public Worker(ITask task, IHostApplicationLifetime appLifeTime) {
            this.task = task;
            this.appLifeTime = appLifeTime;
        }

        protected override async Task ExecuteAsync(CancellationToken stoppingToken) {
            while (!stoppingToken.IsCancellationRequested)
            {
                try {
                    this.task.Execute(stoppingToken);
                } catch (Exception e) {
                    this.appLifeTime.StopApplication();
                }

                await Task.Delay(10000, stoppingToken);
            }
        }
    }

    public interface ITask {
        void Execute(CancellationToken stoppingToken);
    }

Answer 1

你可以按照这些思路做一些事情:

protected override async Task ExecuteAsync(CancellationToken stoppingToken) {
    var cancellationSource = CancellationTokenSource.CreateLinkedTokenSource(stoppingToken);
    cancellationSource.CancelAfter(10000);
    
    return Task.Run(() => task.Execute(cancellationSource.Token));
}

如果你想处理执行和/或等待任务，那么你可以，但这是一个简单的例子。