如何将此长时间运行的后台任务转换为异步/等待？

Question

我的代码正在启动一个带有心跳的长时间运行的后台任务。该应用程序正在更新以使用 async/await，我在更新此代码以遵循套件时遇到问题。大致代码如下：

private void StartBackgroundTasks(CancellationTokenSource cancelTokenSrc)
{
    void TaskAction()
    {
        DoWork();
    }

    void HeartbeatAction()
    {
        var task = TaskFactory.CreateAndStartLongRunningTask(
            TaskAction, cancelTokenSrc.Token);

        while (true)
        {
            // checks Task.Status to figure out when to stop
            if (!TryPerformHeartbeat(task)) break;

            Task.Delay(TimeSpan.FromSeconds(20)).Wait();
        }
    }

    TaskFactory.CreateAndStartLongRunningTask(HeartbeatAction);
}

以下是长时间运行的任务的启动方式：

internal static class TaskFactory
{
    internal static Task CreateAndStartLongRunningTask(
        Action action, CancellationToken? token = null)
    {
        return Task.Factory.StartNew(
            action,
            token ?? CancellationToken.None,
            TaskCreationOptions.LongRunning,
            TaskScheduler.Default);
    }
}

据我了解，我需要：

• 将Func<Task> 传递给CreateAndStartLongRunningTask
• 将StartNew 更改为async () => await taskFunc() 而不是action
• 根据需要通过方法签名添加异步/等待

让这段代码在后台线程上运行并允许异步/等待模式的正确方法是什么？

Answer 1

简而言之，除非您特别需要它，否则您不应使用Task.Factory.StartNew 或TaskCreationOptions.LongRunning。只需像这样使用Task.Run：

var task = Task.Run(async () =>
{
    while (true)
    {
        await TryPerformHeartbeat();
        await Task.Delay(TimeSpan.FromSeconds(20));

    }
}, token);

这两篇文章有助于解释原因： http://blog.i3arnon.com/2015/07/02/task-run-long-running/ 和 https://sergeyteplyakov.github.io/Blog/async/2019/05/21/The-Dangers-of-Task.Factory.StartNew.html