异步和等待 - 处理对同一方法的多次调用 - 相互锁定/等待？

我有一个复杂的基于任务/锁的混乱来执行“长”数据操作，并且我正在尝试用异步/等待替换它。我是异步等待的新手，所以我担心我犯了一些大错误。

为了简化事情，我的 UI 有几个页面依赖于相同的数据。现在，我只需要获取这些数据一次。所以我缓存它，进一步的调用只是从缓存“CachedDataObjects”中获取它，而不是每次都进行长调用。

像这样（半伪代码）：

    private Dictionary<Guid,List<Data>> CachedDataObjects;

    public async Task<List<Data>> GetData(Guid ID)
    {
        List<Data> data = null;

        //see if we have any cached
        CachedDataObjects.TryGetValue(ID, out data);

        if (data == null)
        {
            if (ConnectedToServer)
            {
                data = new List<Data>();
                await Task.Run(() =>
                {
                    try
                    {
                        //long data call
                        data = Service.GetKPI(ID);
                    }
                    catch (Exception e)
                    {
                        //deal with errors (passes an action to do if resolved)
                        PromptForConnection(new Task(async () => { data = await GetData(ID); }), e);
                    }
                });
            }

            CachedDataObjects.Add(ID, data);
        }
        return data;
    }

但是，根据异步调用的性质，两个页面在触发时都会调用此方法。

因此，出现了异常 - 具有该 ID 的项目已添加到字典中。即使我修复了这个问题，根本问题仍然存在。数据对象将是不同的版本，我正在进行两次网络调用，而我应该只有一个等等。

以前，我通过将整个方法封装在一个锁定语句中来“破解”一个解决方案 - 从而只允许对其进行一次调用。我的所有数据加载都是在后台工作人员中完成的，第一个执行调用，一旦完成，其他工作人员就会解锁以执行快速抓取。

但我不能在异步方法中使用锁，并且该解决方案无论如何感觉都不好。

有没有办法使用异步方法来“等待”其他异步调用完成？

你的问题是你await在将任务添加到字典之前先对其进行编辑。在这种情况下，您需要添加task到字典中，这样下一个调用此方法的页面将得到相同的结果task:

public Task<List<Data>> GetData(Guid ID)
{
  Task<List<Data>> task = null;
  CachedDataObjects.TryGetValue(ID, out task);
  if (task == null)
  {
    if (ConnectedToServer)
    {
      task = Task.Run(() =>
      {
        try
        {
          //long data call
          return Service.GetKPI(ID);
        }
        catch (Exception e)
        {
          //deal with errors
        }
      });
    }
    DataObjects.Add(ID, task);
  }
  return task;
}

这将缓存task。然而，如果//deal with errors传播异常，那么这也将缓存该异常。

为了避免这种情况，你可以使用更复杂的代码，或者你可以采用我的AsyncLazy<T> type https://github.com/StephenCleary/AsyncEx.Coordination:

private readonly ConcurrentDictionary<Guid, AsyncLazy<List<Data>>> CachedDataObjects;
public Task<List<Data>> GetData(Guid ID)
{
  var lazy = CachedDataObjects.GetOrAdd(ID, id =>
      new AsyncLazy<List<Data>>(() => Task.Run(() =>
      {
        try
        {
          return Service.GetKPI(ID);
        }
        catch (Exception e)
        {
          //deal with errors
          throw;
        }
      }, AsyncLazyFlags.RetryOnFailure | AsyncLazyFlags.ExecuteOnCallingThread)));
  return lazy.Task;
}