多个并行的可分配任务

本文关键字：可分配 任务 并行 | 更新日期: 2023-09-27 18:23:45

我正在试验提高ASP.NET应用程序性能的方法。我正在研究的一件事是使用并行性并使操作异步，以减少处理时间并提高吞吐量。我开始模仿我们经常做的事情，发布多个数据库检索来呈现一个页面。

public ActionResult Index()
{
    var dal = new Dal();
    var cases = new List<Case>();
    cases.AddRange( dal.GetAssignedCases() );
    cases.AddRange( dal.GetNewCases() );
    return View( "Cases", cases );
}

这两个Dal方法使用Thread.Sleep(2000)来模拟查询，并只返回硬编码对象的集合。我使用ab -c 1 -n 1在ApacheBench上运行这个程序，大约需要4秒钟。我第一次尝试改进它是：

public ActionResult Index()
{
    var dal = new Dal();
    var assignedCases = Task.Factory.StartNew( () => dal.GetAssignedCases() );
    var newCases = Task.Factory.StartNew( () => dal.GetNewCases() );
    IEnumerable<Case>[] allCases = Task.WhenAll( assignedCases, newCases ).Result;
    return View( "Cases", allCases.SelectMany( c => c ) );
}

当我使用相同的ab命令运行时，它显示大约两秒钟，这是有道理的，因为我正在运行两个任务，每个任务需要两秒钟，但它们是并行运行的。

当我将基准更改为10个并发请求（即ab -n 10 -c 10）时，我得到以下内容。

Fulfilled  Original Parallel
 50%         4014     2038
 66%         4015     2039
 75%         4017     4011

其余高达100%的数字在两列中都是相似的。

我假设我在这里遇到的是线程池争用。大约2/3的请求很快就得到了满足，在那之后，事情就一直在等待线程为请求提供服务。所以我想，如果我在混合中添加async，我可能会更快地收到更多的请求。这就是我开始遇到问题的地方，我不知道问题是我模拟长时间查询的方式，还是我使用语言功能的方式，或者我只是完全走错了轨道，隧道尽头的灯是即将到来的火车。：-）

我做的第一件事就是创建一个DalAsync。在DalAsync中，我用await Task.Delay(2000)替换了Thread.Sleep(2000)，用async关键字标记了每个方法，并将返回类型从IEnumerable<Case>更改为Task<IEnumerable<Case>>。然后，我根据在六篇博客文章和MSDN文章中读到的信息，编写了一个新的控制器方法。

public async Task<ActionResult> Index()
{
    var dal = new DalAsync();
    var assignedCases = dal.GetAssignedCasesAsync();
    var newCases = dal.GetNewCasesAsync();
    var allCases = await Task.WhenAll( assignedCases, newCases );
    return View( "Cases", allCases.SelectMany( c => c ) );
}

当我使用ab运行它时，它永远不会完成，即使有一个请求，它也会超时。我还尝试了以下变体，它有效，但返回的数字与原始版本几乎相同（这有点道理，因为我似乎又在序列化查询了）。

var assignedCases = await dal.GetAssignedCasesAsync();
var newCases = await dal.GetNewCasesAsync();
var allCases = new List<Case>( assignedCases );
allCases.AddRange( newCases );

我希望发生的是：

  • 并行运行两个查询
  • 当控制器等待Dal方法响应时，它会释放线程并让其他请求执行

多个并行的可分配任务

您的第一个代码示例应该可以工作，但在我看来有点奇怪。Task.WhenAll被引入为非阻塞操作，即您将使用await Task.WhenAll(myTasks)。通过使用.Result，您将它变成了一个阻塞操作，但是以这种方式使用并不完全自然。

我想你真正想要的是Task.WaitAll(params Task[])，它被设计成一个阻塞操作。

然而，您的第二个代码示例看起来近乎完美，正是我想要的。在整个代码库中实现异步代码总是使实现更加干净。

虽然我无法重现您的案例，我的案例运行正常，但对我来说，您似乎陷入了僵局。尝试强制异步任务将结果返回到不同的同步上下文，如下所示：

public async Task<ActionResult> Index()
{
    var dal = new DalAsync();
    var assignedCases = Task.Run(async () => await dal.GetAssignedCasesAsync());
    var newCases = Task.Run(async () => await dal.GetNewCasesAsync());
    var allCases = await Task.WhenAll( assignedCases, newCases).ConfigureAwait(false);
    return View( "Cases", allCases.SelectMany( c => c ) );
}
相关文章：