在 web api 控制器（.net 核心）中使用 async/await 或任务

Question

我有一个 .net 核心 API，它有一个控制器，用于构建一个聚合对象以返回。 它创建的对象由来自对服务类的 3 个方法调用的数据组成。这些都是相互独立的，可以相互隔离运行。 目前我正在使用任务来提高这个控制器的性能。当前版本看起来像这样......

[HttpGet]
public IActionResult myControllerAction()
{      
    var data1 = new sometype1();
    var data2 = new sometype2();
    var data3 = new List<sometype3>();

    var t1 = new Task(() => { data1 = service.getdata1(); });
    t1.Start();

    var t2 = new Task(() => { data2 = service.getdata2(); });
    t2.Start();

    var t3 = new Task(() => { data3 = service.getdata2(); });
    t3.Start();

    Task.WaitAll(t1, t2, t3);

    var data = new returnObject
    {
         d1 = data1,
         d2 = data2,
         d2 = data3
    };

    return Ok(data);
}

这很好，但是我想知道使用任务是否是最好的解决方案？使用 async/await 会是更好的主意和更被接受的方式吗？

例如，控制器是否应该被标记为异步并在每次调用服务方法时放置等待？

Answer 1

据我了解，您希望它并行执行，所以我认为您的代码没有任何问题。正如 Gabriel 所说，您可以等待任务完成。

[HttpGet]
public async Task<IActionResult> myControllerAction()
{      
  var data1 = new sometype1();
  var data2 = new sometype2();
  var data3 = new List<sometype3>();

  var t1 = Task.Run(() => { data1 = service.getdata1(); });
  var t2 = Task.Run(() => { data2 = service.getdata2(); });
  var t3 = Task.Run(() => { data3 = service.getdata3(); });

  await Task.WhenAll(t1, t2, t3); // otherwise a thread will be blocked here

  var data = new returnObject
  {
      d1 = data1,
      d2 = data2,
      d2 = data3
  };

 return Ok(data);
}

您还可以使用任务的结果来保存一些代码行并使代码整体“更好”（参见 cmets）：

[HttpGet]
public async Task<IActionResult> myControllerAction()
{      
  var t1 = Task.Run(() => service.getdata1() );
  var t2 = Task.Run(() => service.getdata2() );
  var t3 = Task.Run(() => service.getdata3() );

  await Task.WhenAll(t1, t2, t3); // otherwise a thread will be blocked here

  var data = new returnObject
  {
      d1 = t1.Result,
      d2 = t2.Result,
      d2 = t3.Result
  };

 return Ok(data);
}

Answer 2

这很好用，但是我想知道使用任务是否是最好的解决方案？使用 async/await 会是更好的主意和更被接受的方式吗？

是的，当然。在 ASP.NET 上进行并行处理会消耗每个请求的多个线程，这会严重影响您的可伸缩性。对于 I/O，异步处理要好得多。

要使用async，首先从您的最低级别调用开始，在您的服务中的某处。它可能会在某个时候进行 HTTP 调用；将其更改为使用异步 HTTP 调用（例如，HttpClient）。然后让async从那里自然生长。

最终，您将得到异步的 getdata1Async、getdata2Async 和 getdata3Async 方法，它们可以同时使用：

[HttpGet]
public async Task<IActionResult> myControllerAction()
{
  var t1 = service.getdata1Async();
  var t2 = service.getdata2Async();
  var t3 = service.getdata3Async();
  await Task.WhenAll(t1, t2, t3);

  var data = new returnObject
  {
    d1 = await t1,
    d2 = await t2,
    d3 = await t3
  };

  return Ok(data);
}

使用这种方法，当三个服务调用正在进行时，myControllerAction 使用 零 个线程而不是 四个。

Answer 3

[HttpGet]
public async Task<IActionResult> GetAsync()
{      
    var t1 = Task.Run(() => service.getdata1());
    var t2 = Task.Run(() => service.getdata2());
    var t3 = Task.Run(() => service.getdata3());

    await Task.WhenAll(t1, t2, t3);

    var data = new returnObject
    {
        d1 = t1.Status == TaskStatus.RanToCompletion ? t1.Result : null,
        d2 = t2.Status == TaskStatus.RanToCompletion ? t2.Result : null,
        d3 = t3.Status == TaskStatus.RanToCompletion ? t3.Result : null
    };

   return Ok(data);
}

1. 当您等待任务时，您的操作线程当前被阻塞。使用 TaskWhenAll 返回可等待的任务对象。因此，使用异步方法，您可以等待任务而不是阻塞线程。
2. 您可以使用Task<T> 返回所需类型的结果，而不是创建局部变量并在任务中分配它们。
3. 不用创建和运行任务，而是使用Task<TResult>.Run方法
4. 我建议对动作名称使用约定 - 如果动作接受 GET 请求，它的名称应该以 Get 开头
5. 接下来，您应该检查任务是否成功完成。这是通过检查任务状态来完成的。在我的示例中，如果某些任务未成功完成，我使用 null 值作为返回对象属性。您可以使用另一种方法 - 例如如果某些任务失败，则返回错误。