Jak nawodnić słownik z wynikami połączeń asynchronicznych?

Question

Załóżmy, że mam kodu, który wygląda tak:

public async Task<string> DoSomethingReturnString(int n) { ... } 
int[] numbers = new int[] { 1, 2 , 3}; 

Załóżmy, że chcę utworzyć słownik, który zawiera wynik wywołania DoSomethingReturnString dla każdego numeru podobnego do tego:

Dictionary<int, string> dictionary = numbers.ToDictionary(n => n, 
    n => DoSomethingReturnString(n)); 

który wygrał” t działa, ponieważ funkcja DoSomethingReturnString zwraca wartość Task<string> zamiast string. Intellisense zasugerował, żebym spróbował określić moje wyrażenie lambda jako asynchroniczne, ale to też nie rozwiązało problemu.

Answer 1

Jeśli dzwonisz z metody asynchronicznego, można napisać metodę otoki, który tworzy nowy słownik i buduje słownika przez Iterowanie nad każdym numerem, nazywając swój DoSomethingReturnString kolejno:

public async Task CallerAsync() 
{ 
    int[] numbers = new int[] { 1, 2, 3 }; 
    Dictionary<int, string> dictionary = await ConvertToDictionaryAsync(numbers); 
} 

public async Task<Dictionary<int, string>> ConvertToDictionaryAsync(int[] numbers) 
{ 
    var dict = new Dictionary<int, string>(); 

    for (int i = 0; i < numbers.Length; i++) 
    { 
     var n = numbers[i]; 
     dict[n] = await DoSomethingReturnString(n); 
    } 

    return dict; 
} 

Answer 2

Jeśli domagać się robi to z LINQ, Task.WhenAll jest kluczem do „hydrat” w słowniku:

int[] numbers = new int[] { 1, 2 , 3}; 
KeyValuePair<int, string>[] keyValArray = //using KeyValuePair<,> to avoid GC pressure 
    await Task.WhenAll(numbers.Select(async p => new KeyValuePair<int, string>(p, await DoSomethingReturnString(p)))); 
Dictionary<int, string> dict = keyValArray.ToDictionary(p => p.Key, p => p.Value); 

Answer 3

metody LINQ nie wspierać działania asynchronicznych (np selektorów wartości asynchroniczny), ale można tworzyć samemu. Oto wielokrotnego użytku ToDictionaryAsync metodę rozszerzenia, które obsługuje selektor wartość asynchronicznego:

public static class ExtensionMethods 
{ 
    public static async Task<Dictionary<TKey, TValue>> ToDictionaryAsync<TInput, TKey, TValue>(
     this IEnumerable<TInput> enumerable, 
     Func<TInput, TKey> syncKeySelector, 
     Func<TInput, Task<TValue>> asyncValueSelector) 
    { 
     Dictionary<TKey,TValue> dictionary = new Dictionary<TKey, TValue>(); 

     foreach (var item in enumerable) 
     { 
      var key = syncKeySelector(item); 

      var value = await asyncValueSelector(item); 

      dictionary.Add(key,value); 
     } 

     return dictionary; 
    } 
} 

Można go używać tak:

private static async Task<Dictionary<int,string>> DoIt() 
{ 
    int[] numbers = new int[] { 1, 2, 3 }; 

    return await numbers.ToDictionaryAsync(
     x => x, 
     x => DoSomethingReturnString(x)); 
}