具有返回值的 Hangfire 后台作业

Question

我正在从 Task.Run 切换到 Hangfire。在 .NET 4.5+ 中，Task.Run 可以返回 Task<TResult>，这允许我运行返回 void 以外的任务。我通常可以通过访问属性MyReturnedTask.Result 来等待并获得我的任务结果

我的旧代码示例：

public void MyMainCode()
{
    List<string> listStr = new List<string>();
    listStr.Add("Bob");
    listStr.Add("Kate");
    listStr.Add("Yaz");

    List<Task<string>> listTasks = new List<Task<string>>();

    foreach(string str in listStr)
    {
        Task<string> returnedTask = Task.Run(() => GetMyString(str));
        listTasks.Add(returnedTask);
    }

    foreach(Task<string> task in listTasks)
    {
        // using task.Result will cause the code to wait for the task if not yet finished.
        // Alternatively, you can use Task.WaitAll(listTasks.ToArray()) to wait for all tasks in the list to finish.
        MyTextBox.Text += task.Result + Environment.NewLine;
    }
}
private string GetMyString(string str)
{
    // long execution in order to calculate the returned string
    return str + "_finished";
}

据我在 Hangfire 的 Quick Start 页面上看到的，你的主要人物是 BackgroundJob.Enqueue(() => Console.WriteLine("Fire-and-forget")); 完美地将代码作为后台作业运行，但显然不支持具有返回值的作业（如我上面介绍的代码）。那正确吗？如果没有，我该如何调整我的代码以使用 Hangfire？

附：我已经看过HostingEnvironment.QueueBackgroundWorkItem (here) 但它显然缺少相同的功能（后台作业必须是void）

编辑

正如@Dejan 发现的那样，我想切换到 Hangfire 的主要原因与 .NET 人员在 .NET 4.5.2 中添加 QueueBackgroundWorkItem 的原因相同。这个原因在 Scott Hanselman 关于 ASP.NET 中的后台任务的精彩 article 中得到了很好的描述。所以我要引用这篇文章：

QBWI (QueueBackgroundWorkItem) 调度一个可以在后台运行的任务，独立于 任何请求。这与普通的 ThreadPool 工作项的不同之处在于 ASP.NET 自动跟踪注册了多少工作项 通过此 API 当前正在运行，并且 ASP.NET 运行时将 尝试延迟 AppDomain 关闭，直到这些工作项目完成 正在执行。

Answer 1

一个简单的解决方案是轮询监控 API，直到作业完成，如下所示：

    public static Task Enqueue(Expression<Action> methodCall)
    {
        string jobId = BackgroundJob.Enqueue(methodCall);
        Task checkJobState = Task.Factory.StartNew(() =>
        {
            while (true)
            {
                IMonitoringApi monitoringApi = JobStorage.Current.GetMonitoringApi();
                JobDetailsDto jobDetails = monitoringApi.JobDetails(jobId);
                string currentState = jobDetails.History[0].StateName;
                if (currentState != "Enqueued" && currentState != "Processing")
                {
                    break;
                }
                Thread.Sleep(100); // adjust to a coarse enough value for your scenario
            }
        });
        return checkJobState;
    }

注意：当然，在 Web 托管的场景中，您不能依靠继续执行任务 (task.ContinueWith()) 在作业完成后做更多的事情，因为 AppDomain 可能会被关闭- 出于同样的原因，您可能首先想使用 Hangfire。