async cuộc gọi trong phạm vi chức năng đồng bộ

Question

Tôi đang cố gắng để cư trú bộ nhớ cache của tôi không đồng bộ

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) {....} 

nhưng điều này mang lại cho tôi những lỗi:

Cannot convert async lambda expression to delegate type 'System.Func'.

An async lambda expression may return void, Task or Task, none of which are convertible to 'System.Func'.

Như tôi hiểu điều này là bởi vì GetOrAdd() không phải là không đồng bộ. Làm cách nào để khắc phục sự cố?

Cập nhật: LazyAsync gợi ý trong các ý kiến ​​sẽ làm việc trong ví dụ tầm thường của tôi. Hoặc, workaround như thế này (chắc chắn có thể sống chung với một số phí nó giới thiệu):

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

Câu hỏi đặt ra sau đó trở nên đã làm Microsoft chỉ không có thời gian để cập nhật tất cả các giao diện để hỗ trợ async hay tôi đang cố gắng để làm một cái gì đó sâu sắc sai (và ConcurrentDictionary không nên có GetOrAddAsync())?

Answer 1

Phương thức không đồng bộ (hoặc lambda) chỉ có thể trả lại void hoặc Task hoặc Task<T> nhưng lambda của bạn trả lại string[] và do đó trình biên dịch ngăn bạn.

await từ khóa được tối ưu hóa để tiếp tục đồng bộ khi Tác vụ đã được hoàn thành. Vì vậy, một tùy chọn là để lưu trữ các nhiệm vụ chính nó trong từ điển và không lo lắng về việc chờ đợi nhiệm vụ hoàn thành một lần nữa và một lần nữa.

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

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

Và khi bạn làm

var item = await GetStuffAsync(...); 

lần đầu tiên nó sẽ (a) chờ đến khi công tác lưu trữ kết thúc --There sau đó sẽ tiếp tục đồng bộ.

Bạn sẽ phải suy nghĩ về điều gì sẽ xảy ra khi LoadAsync không thành công. Bởi vì chúng tôi đang lưu vào bộ nhớ cache Tác vụ được trả về bởi LoadAsync; nếu điều đó không thành công, chúng tôi sẽ xóa nhầm nhiệm vụ không thành công. Bạn có thể cần phải xử lý việc này.