同步函数中的异步调用

Question

我正在尝试异步填充我的缓存

static ConcurrentDictionary<string, string[]> data = new ConcurrentDictionary<string, string[]>();

public static async Task<string[]> GetStuffAsync(string key)
{
    return data.GetOrAdd(key, async (x) => {
        return await LoadAsync(x);
    });
}

static async Task<string[]> LoadAsync(string key) {....}

但这给了我错误：

无法将异步 lambda 表达式转换为委托类型“System.Func”。

异步 ​​lambda 表达式可能返回 void、Task 或 Task，它们都不能转换为 'System.Func'。

据我了解，这是因为 GetOrAdd() 不是异步的。我该如何解决这个问题？

更新： cmets 中建议的LazyAsync 将适用于我的简单示例。或者，像这样的解决方法（肯定可以忍受它引入的一些开销）：

public static async Task<string[]> GetStuffAsync(string key)
{
    string[] d = null;
    if (!data.ContainsKey(key))
        d = await LoadAsync(key);
    return data.GetOrAdd(key, d);
}

那么问题就变成了微软只是没有时间更新所有接口以支持异步还是我试图做一些严重错误的事情（ConcurrentDictionary 不应该有GetOrAddAsync()）？

Answer 1

异步方法（或 lambda）只能返回 void 或 Task 或 Task<T> 但您的 lambda 返回 string[]，因此编译器会阻止您。

await 关键字被优化为在任务已经完成时同步继续。因此，一种选择是将任务本身存储在字典中，而不必担心一次又一次地等待完成的任务。

private static ConcurrentDictionary<string, Task<string[]>> data =
    new ConcurrentDictionary<string, Task<string[]>>();

public static Task<string[]> GetStuffAsync(string key)
{
    return data.GetOrAdd(key, LoadAsync);
}

当你这样做时

var item = await GetStuffAsync(...);

第一次它会（a）等到缓存的任务完成——之后它将同步继续。

您必须考虑当LoadAsync 失败时会发生什么。因为我们正在缓存LoadAsync 返回的任务；如果失败，我们将愚蠢地缓存失败的任务。您可能需要处理这个问题。