如何从异步方法中获取对象？

Question

问题
如何从异步方法中获取对象？

说明
我正在尝试做一个类似的项目。
项目链接 - Link // github.com ;
我尝试重复该方法-GetPosts (int index, int pageSize, string tag = null)。

public async Task<Page<Post>> GetPosts(int index, int pageSize, string tag = null)
    {
        var result = new Page<Post>() { CurrentPage = index, PageSize = pageSize };

        using (var context = ContextFactory.CreateDbContext(ConnectionString))
        {
            var query = context.Posts.AsQueryable();
            if (!string.IsNullOrWhiteSpace(tag))
            {
                query = query.Where(p => p.Tags.Any(t => t.TagName == tag));
            }

            result.TotalPages = await query.CountAsync();
            result.Records = await query.Include(p => p.Tags).Include(p => p.Comments).OrderByDescending(p => p.CreatedDate).Skip(index * pageSize).Take(pageSize).ToListAsync();
        }

        return result;
    }

我想用任意请求创建一个类似的异步方法。
例如一个查询：query = query.Where (p => p.ContactName.Contains (" Maria "));.
我尝试做一个简单的方法：

public Customer GetCustomers ()
{
    Customer result = new Customer ();
 
    using (var context = ContextFactory.CreateDbContext (ConnectionString))
    {
      var query = context.Customers.AsQueryable ();
      query = query.Where (p => p.ContactName.Contains ("Maria")); //
      result = query as Customer;
    }
    return result;
}

 
字符串query = query.Where (p => p.ContactName.Contains (" Maria "));中的结果见图。

问题。
如何使这样的方法与相同或不同的请求异步？

尝试次数 - 1. 结果 - 无效。

public Task <Customer> GetCustomersTask ()
        {
            // Customer result = new Customer ();
 
            var result = new TaskCompletionSource <Customer> ();
 
            using (var context = ContextFactory.CreateDbContext (ConnectionString))
            {
                Task.Run (() =>
                {
                    var query = context.Customers.AsQueryable ();
                    query = query.Where (p => p.ContactName == "Maria");
 
                    result.SetResult (query as Customer);
                }
                );
            }
            return result.Task;
        }

图片1

图片2

---

更新 1。##

根据答案的材料：马丁。 link

我正在使用该方法。

 public async Task <Customer> GetCustomerAsync ()
{
    Customer result = new Customer ();

    using (var context = ContextFactory.CreateDbContext (ConnectionString))
    {
      var query = context.Customers.AsQueryable ();
      query = query.Where (p => p.ContactName.Contains ("Maria")); //
      var results = await query.ToListAsync ();
      result = results.FirstOrDefault ();
    }
    return result;
}

我收到一个错误：
“IQueryable”不包含“ToListAsync”的定义， 并且找不到可用的扩展方法“ToListAsync”， 主机类型“IQueryable”作为第一个 参数（可能使用指令或程序集引用缺失）。

图片1

---

更新 2

由using Microsoft.EntityFrameworkCore;添加。
现在类命名空间的形式为：
using DBRepository.Interfaces;
using Models;
using System;
using System.Threading.Tasks;
using System.Linq;
using Microsoft.EntityFrameworkCore;

错误（参见 Update-1）：
"IQueryable" does not contain a definition of "ToListAsync", and could not find an available extension method "ToListAsync", host type "IQueryable" as the first argument (possibly using directive or assembly reference missing). 消失了。

说明。
我正在调试。
我进入字符串var results = await query.ToListAsync ();(of classICustomerRepositoryAnsw.GetCustomersTask1 ());
我按 F11。
我进入字符串string result =" ";（类TestAnsw方法GetCustomersTask_Test()（此方法调用ICustomerRepositoryAnsw.GetCustomersTask1()）。
结果：调试不执行字符串result = results.FirstOrDefault ();和return result;

问题。
1、为什么result = results.FirstOrDefault ();和return result;这行没有执行？

图片1

图片2

Answer 1

模板上有很好的文档async/await - here（我已经在上面的评论中写过）。
作为总结，我可以说：
Task <T> 或 async NOT 使方法异步。
只有await 关键字使方法异步。

因此，如果您希望方法以非阻塞方式运行，则必须对 EntityFramework 使用异步 API/Framework 调用。

public Task<Customer> GetCustomerAsync ()
{
    Customer result = new Customer ();

    using (var context = ContextFactory.CreateDbContext (ConnectionString))
    {
      var query = context.Customers.AsQueryable ();
      query = query.Where(p => p.ContactName.Contains ("Maria")); //
      result = query.FirstOrDefault();
    }
    return Task.FromResult(result);
}

看起来是异步的，但不是。

但是如果你使用扩展方法.ToListAsync()

public async Task<Customer> GetCustomerAsync ()
{
    Customer result = new Customer ();

    using (var context = ContextFactory.CreateDbContext (ConnectionString))
    {
      var query = context.Customers.AsQueryable ();
      query = query.Where (p => p.ContactName.Contains ("Maria")); //
      var results = await query.ToListAsync();
      result = results?.FirstOrDefault();
    }
    return result;
}

现在您可以通过以下方式调用此实现：

var customer = await YourClass.GetCustomerAsync();

Then it will run non-blocking async.

EntityFramework Core