异步 Linq 查询

Question

我正在学习 Linq。该示例使用 Northwind 数据库。我正在尝试使以下方法异步：

public IActionResult ProductsThatCostMoreThan(decimal price)
{
    var model = db.Products
        .Include(p => p.Category)
        .Include(p => p.Supplier)
        .AsEnumerable()
        .Where(p => p.UnitPrice > price);
    return View(model);
}

如果尝试了下面的代码，但编译器抱怨IAsyncEnumerable<Product> 不包含Where 的定义，并且找不到接受IAsyncEnumerable<Product> 类型的第一个参数的可访问扩展方法“Where”。删除 where 表达式可解决此问题。如何编写异步 where 过滤器？

public async Task<IActionResult> ProductsThatCostMoreThanAsync(decimal price)
{
    var model = await db.Products
       .Include(p => p.Category)
       .Include(p => p.Supplier)
       .AsAsyncEnumerable()
       .Where(p => p.UnitPrice > price);
    return View(model);
}

尝试澄清：我将尝试更好地解释问题的上下文。这是一本书的学术练习，我正在尝试从中学习 Linq。

该方法是 Asp.net Core MVC 网站中的控制器操作方法。我了解到，如果控制器操作方法很慢（例如，它需要从数据库中获取大量数据），它会限制网站的可扩展性，因为该方法会锁定 Web 服务器线程池中的一个线程，直到它完成。使控制器中的操作方法异步将线程释放回池中，以便在方法执行缓慢的操作时可以重用它。 （见https://docs.microsoft.com/en-us/archive/msdn-magazine/2014/october/async-programming-introduction-to-async-await-on-asp-net）。

例如：

public IActionResult Index()
{
    var model = new HomeIndexViewModel
    {
        Categories = db.Categories.ToList()
    };
    return View(model);
}

为此更改为以下内容：

public async Task<IActionResult> Index()
{
    var model = new HomeIndexViewModel
    {
         Categories = await db.Categories.ToListAsync(),
    };
    return View(model);
}

我正在尝试对问题顶部的方法进行类似的更改。

Answer 1

Async 在你实际做某事时出现。

只要您正在设置查询，从 task 的角度来看，使事情异步是没有意义的。

我给你举个例子；

设置查询

以下代码是关于设置查询的：

var query = db.Products
    .Include(p => p.Category)
    .Include(p => p.Supplier)
    .Where(p => p.UnitPrice > price)
    .OrderBy(c => c.SomeProperty)
    .Etc...;

在您实际枚举结果之前，不会执行上述查询。因此;在这一点上，async Task 不相关（好吧，在 99.99999% 的情况下）。

---

执行异步

那么你什么时候使用Task（async如果你喜欢）

在具体化查询时使用它； IE。;执行/枚举它：

最著名的例子是这样的：

var result = await query.ToListAsync();

顺便说一句，这就是为什么你有更多这样的助手：

• 单异步，
• 第一异步，

---

问题：

如何编写异步 where 过滤器？

您很可能不需要。您希望异步执行过滤器，即；访问您的数据库或其他来源。

在具体化的时候，即； ToListAsync-ing，您希望将其作为Task 执行。

Answer 2

我假设您在这里使用 EntityFamework。在这种情况下（正如其他答案指出的那样），您可以像这样选择.ToListAsync()：

public async IActionResult ProductsThatCostMoreThan(decimal price)
{ 
    var model = await db.Products
                               .Include(p => p.Category)
                               .Include(p => p.Supplier)
                               .Where(p => p.UnitPrice > price).ToListAsync();
     return View(model); 
}

你必须在你的链末尾有它的原因是因为它返回Task，而不是 IEnumerable，所以你必须等待它。从技术上讲，您可以在没有过滤器的情况下枚举您的数据源，等待它，然后应用 .Where。但是 EF 的工作方式会将您的 .Where 子句编译为 SQL 代码，因此它必须是原始方法链的一部分

还有一点要说明的是，此扩展方法是 EF 程序集的一部分，因此如果您不使用 EF，您可能不得不寻找替代方法。正如其他答案指出的那样，实际查询执行发生在您调用枚举 IEnumerable 时，因此您可以在技术上编写具有类似效果的自己的扩展方法（最简单的是检查 EF 的扩展源）