任务和异步等待需要指导[重复]

Question

在浏览了很多文章和视频后，我仍然对异步编程有疑问。我正在做一个项目，在服务层中，我将所有方法都创建为异步。所有返回Task <T> 或Task（我确保不返回无效）。 现在到了这个问题。我的 Api 调用异步方法，这些方法在内部调用其他异步方法，甚至可能调用其他异步方法。所以每次遇到异步方法时我都在等待。 我认为这种方法的缺点是因为每次遇到异步时我都在等待结果，这将花费很多时间。例如：

public async Task<xyz> DoMainTask(int ActionId, int ItemId, int UserId)
{
   await DoTask1(ActionId,ItemId,UserId);  3 sec
   await DoTask2(ActionId,ItemId,UserId);  3 sec
   await DoTask3(ActionId,ItemId,UserId);  3 sec
}

所以我不想等待 9 秒，因为这里的所有任务都是相互独立的。 我想做类似的事情：

public async Task<xyz> DoMainTask(int ActionId, int ItemId, int UserId)
{
   List<Task> lst = new List<Task>();
   t1= DoTask1(ActionId,ItemId,UserId);  
   lst.Add(t1);

   t2 = DoTask2(ActionId,ItemId,UserId);
   lst.Add(t2);

   t3 = DoTask3(ActionId,ItemId,UserId);
   lst.Add(t3);

   await Task.WhenAll(lst);

   // do some work
   return xyz;
}

这可能需要大约 5-6 秒。我该怎么做呢？ 每当我尝试使用第二种方法时，它都会出错：

在前一个异步操作完成之前在此上下文上启动了第二个操作

DoTask1 定义为：

  public async Task DoTask1 (int ActionId, int ItemId, int UserId)
    {
        try
        {
            DailyActivityPoint dailyActivityPoint = new DailyActivityPoint()
            {
                ActionId = ActionId,
                CreatedDate = DateTime.Now,
                ItemId = ItemId,
                UserId = UserId,
                PointsAccumulated = await GetPointsAwardedForAction(ActionId)
            };

            _entities.DailyActivityPoints.Add(dailyActivityPoint);
            await _entities.SaveChangesAsync();
        }
        catch (Exception ex)
        {

        }
    }

在 DoTask1 内部，我也在调用异步方法。

如何做到这一点，最佳做法是什么？

Answer 1

我相信您遇到了here 所述的线程安全问题。如果是这样，您需要确保每个进入 EF 的“等待”都使用自己的 DbContext 实例。

所以，请确保您没有使用 DbContext 单例；如果可以的话，随时实例化一个新容器，或者像他在链接中那样使用容器（容器是你的朋友）

Answer 2

也许您应该在编写异步方法时使用此指南

指南：

1. 按照编写常规方法的正常方式编写方法，然后将其转换为异步方法。

2. 在方法声明中使用 async 关键字。

   public async Task<int> ExampleMethodAsync()  
   {  
       // . . . .  
   } 
   

3. 在调用异步进程/方法的代码中使用 await 关键字。

     int resultValue = await ExampleMethodAsync();
   

注意： await 只能用在 async 关键字修改的异步方法中。

4. 在异步方法中使用正确的返回类型之一以获得结果

   return types for an async method need to be one of the following:
   

   • 如果您的方法有一个返回语句，其中操作数的类型为 TResult，则为任务。
   • 如果您的方法没有 return 语句或有一个没有操作数的 return 语句，则执行任务。
   • 如果您正在编写异步事件处理程序，则无效。

5. 在调用方法名称的末尾添加“Async”后缀。这不是必需的，但可以考虑 在 C# 中编写异步方法的约定。

   public async Task<int> ExampleCallingMethodAsync()  
   {  
       // . . . .  
   }
   

6. 在异步方法代码中至少包含一个等待表达式。 在等待表达式处暂停异步方法不会 构成方法的退出，finally 块不运行。

   public async Task<int> ExampleMethodAsync()  
   {  
    //some code
    string pageContents = await client.GetStringAsync(uri);   
    //some more code
    return pageContents.Length;
   }
   

   注意：

   1. 您必须调整异步方法返回的内容。返回的对象必须与你的异步方法的类型 Task<T> 匹配
   2. 如果异步方法不使用等待运算符来标记暂停点，则该方法 尽管有 async 修饰符，但仍像同步方法一样执行。编译器发出一个 此类方法的警告。

---

下面是转换为异步方法的典型方法

示例

    private void WebPage(string someURI) 
 { 
    WebClient webClient = new WebClient(); 
    string pageContent = webClient.DownloadString(someURI);
    Console.WriteLine(pageContent);
 }

改为：

   private async void WebPageAsync(string someURI)
 { 
  WebClient webClient = new WebClient();
  string pageContent = await webClient.DownloadStringTaskAsync(someURI); 
  Console.WriteLine(pageContent); 
 }

我希望这有帮助吗？