c# - 如果没有等待完成，BackgroundService 永远不会启动/停止

Question

在 ASP.NET Core 上，我观察到一种奇怪的行为，这实际上在 BackgroundService not shutting down, stoppingToken never set with .net core generic host 中报告过。但从未找到根本原因

我正在创建以下 BackgroundService 任务，注册为 HostedService :

唯一的方法是这样实现的:

 protected override async Task ExecuteAsync(CancellationToken cancellationToken)
 {
     while (!cancellationToken.IsCancellationRequested )
         Console.WriteLine("running");
 }

如果我尝试Ctrl+C或kill -15，它不会停止。

如果我像这样更改函数:

protected override async Task ExecuteAsync(CancellationToken cancellationToken)
{
    while (!cancellationToken.IsCancellationRequested )
    { 
        Console.WriteLine("running");
        await Task.Delay(1);
    }
}

这有效:如果我尝试 Ctrl+C 该程序，则会设置取消 token ，然后退出。

如果我返回到不起作用的版本并暂停它，我会发现即使我处于 ExecuteAsync 方法中，它下面的框架也是 StartAsync()，在这种情况下它永远不会完成!

我看到的 StartAsync() 代码(来自框架)是这样的:

public virtual Task StartAsync(CancellationToken cancellationToken)
{
    // Store the task we're executing
    _executingTask = ExecuteAsync(_stoppingCts.Token);

    // If the task is completed then return it, this will bubble cancellation and failure to the caller
    if (_executingTask.IsCompleted)
    {
        return _executingTask;
    }

    // Otherwise it's running
    return Task.CompletedTask;
}

那么，这是怎么回事？

我有 2 个问题:

1. 为什么 ExecuteAsync 不在线程池的另一个线程中从一开始就运行？我假设对 _executingTask = ExecuteAsync(_stoppingCts.Token); 的调用会立即返回，但显然情况并非如此，它正在等待第一个等待执行之后的行

2. 我的BackgroundService代码是否不正确？据我所知，在异步函数中使用纯阻塞代码是合法的用例，它不应该导致整个应用程序永远阻塞

Answer 1

docs 中几乎涵盖了这一点。 :

ExecuteAsync(CancellationToken)is called to run the background service. The implementation returns a System.Threading.Tasks.Task that represents the entire lifetime of the background service. No further services are started until ExecuteAsync becomes asynchronous, such as by calling await. Avoid performing long, blocking initialization work in ExecuteAsync.

简单的修复方法是在 ExecuteAsync 开始时调用 await Task.Yield():

protected override async Task ExecuteAsync(CancellationToken cancellationToken)
{
    await Task.Yield();
    // ... rest of the code
}

请注意，您的初始实现应该会产生一条警告，提示缺少 await ，这暗示您可能正在做某事 not entirely correct .