Task.Run 增加 IO 绑定操作的并行性？

Question

我对@9​​87654321@ 以及我在互联网上读到的所有内容感到有些困惑。所以这是我的情况：我有一些处理传入套接字数据的函数：

public async Task Handle(Client client)
{
    while (true)
    {
        var data = await client.ReadAsync();
        await this.ProcessData(client, data);
    }
}

但这有一个缺点，我只能在处理完最后一个请求后才能读取下一个请求。所以这里有一个修改版：

public async Task Handle(Client client)
{
    while (true)
    {
        var data = await client.ReadAsync();
        Task.Run(async () => {
            await this.ProcessData(client, data);
        });            
    }
}

这是一个简化的版本。对于更高级的，我当然会限制并行请求的最大数量。

无论如何，这个ProcessData 主要是 IO 绑定的（对 dbs 进行一些调用，非常轻量级的处理并将数据发送回client）但我一直在阅读我应该将Task.Run 与 CPU 绑定函数一起使用。

对于我的情况，Task.Run 的正确用法是否正确？如果没有，还有什么替代方案？

Answer 1

从概念上讲，这是Task.Run 的一个很好的用法。这与 ASP.NET 分派请求的方式非常相似：（异步）读取请求，然后分派（同步或异步）工作到线程池。

在实践中，您需要确保正确处理ProcessData 的结果。特别是，您需要观察异常。就目前的代码而言，来自ProcessData 的任何异常都将被吞没，因为从Task.Run 返回的任务未被观察到。

IMO，处理每条消息错误的最简单方法是拥有自己的try/catch，例如：

public async Task Handle(Client client)
{
  while (true)
  {
    var data = await client.ReadAsync();
    Task.Run(async () => {
      try { await this.ProcessData(client, data); }
      catch (Exception ex) {
        // TODO: handle
      }
    });            
  }
}

// TODO: handle 是适合您的应用程序的错误处理代码。例如，您可能会在套接字上发送错误响应，或者只是记录并忽略。