c# - ASP.NET Core 中具有托管服务的并行排队后台任务

Question

我正在使用版本 2.1 中的 ASP.NET Core 托管服务新后台任务功能进行一些测试，更具体地说，是队列后台任务，我想到了一个关于并行性的问题。

我目前严格按照 Microsoft 提供的教程进行操作，在尝试模拟工作负载时，同一用户发出多个请求以将任务排队，我注意到所有工作项都按顺序执行，因此没有并行性。

我的问题是，这种行为是预期的吗？如果是这样，为了使请求并行执行，是否可以触发并忘记，而不是等待 workItem 完成？

我已经针对这个特定场景搜索了几天，但没有成功，所以如果有人可以提供任何指南或示例，我将非常高兴。

编辑:教程中的代码很长，所以它的链接是https://learn.microsoft.com/en-us/aspnet/core/fundamentals/host/hosted-services?view=aspnetcore-2.1#queued-background-tasks

执行工作项的方法是这样的:

public class QueuedHostedService : IHostedService
{
    ...

    public Task StartAsync(CancellationToken cancellationToken)
    {
        _logger.LogInformation("Queued Hosted Service is starting.");

        _backgroundTask = Task.Run(BackgroundProceessing);

        return Task.CompletedTask;
    }

    private async Task BackgroundProceessing()
    {
        while (!_shutdown.IsCancellationRequested)
        {
            var workItem = 
                await TaskQueue.DequeueAsync(_shutdown.Token);

            try
            {
                await workItem(_shutdown.Token);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, 
                    $"Error occurred executing {nameof(workItem)}.");
            }
        }
    }

    ...
}

这个问题的重点是想知道是否有人可以分享如何使用这种特定技术同时执行多个工作项的知识，因为服务器可以处理这个工作量。

我在执行工作项时尝试了即发即忘的方法，它按照我预期的方式工作，同时并行执行多个任务，我只是不确定这是否是一个好的做法，或者是否有更好或适当的方法来处理这种情况。

Answer 1

您发布的代码按顺序执行排队的项目，一次一个，但也并行到网络服务器。 IHostedService 根据定义与 Web 服务器并行运行。 This这篇文章提供了一个很好的概述。

考虑以下示例:

_logger.LogInformation ("Before()");
for (var i = 0; i < 10; i++)
{
  var j = i;
  _backgroundTaskQueue.QueueBackgroundWorkItem (async token =>
  {
    var random = new Random();
    await Task.Delay (random.Next (50, 1000), token);
    _logger.LogInformation ($"Event {j}");
  });
}
_logger.LogInformation ("After()");

我们添加了 10 个随机等待时间的任务。如果将代码放在 Controller 方法中，即使在 Controller 方法返回后，事件仍将被记录。但是每个项目都将按顺序执行，因此输出如下所示:

Event 1
Event 2
...
Event 9
Event 10

为了引入并行性，我们必须更改 QueuedHostedService 中的 BackgroundProceessing 方法的实现。

---

这是一个允许并行执行两个任务的示例实现:

private async Task BackgroundProceessing()
{
  var semaphore = new SemaphoreSlim (2);

  void HandleTask(Task task)
  {
    semaphore.Release();
  }

  while (!_shutdown.IsCancellationRequested)
  {
    await semaphore.WaitAsync();
    var item = await TaskQueue.DequeueAsync(_shutdown.Token);

    var task = item (_shutdown.Token);
    task.ContinueWith (HandleTask);
  }
}

使用此实现，事件记录的顺序不再按顺序排列，因为每个任务等待的时间都是随机的。所以输出可能是:

Event 0
Event 1
Event 2
Event 3
Event 4
Event 5
Event 7
Event 6
Event 9
Event 8

---

编辑:在生产环境中以这种方式执行代码而不等待它是否可以？

我认为大多数开发者对即发即弃有问题的原因是它经常被滥用。

当您使用即发即弃执行 Task 时，您基本上是在告诉我您不关心此函数的结果。您不关心它是否成功退出、是否被取消或是否抛出异常。但对于大多数任务，您确实关心结果。

• 您确实想确保数据库写入通过
• 您确实想确保将日志条目写入硬盘
• 你确实想确保网络数据包被发送到接收者

如果您关心 Task 的结果，那么即发即弃是错误的方法。

在我看来就是这样。困难的部分是找到一个您真正不关心 Task 结果的 Task。