如何访问调用异步方法时可用的变量？

Question

动物名称是从 API 中获取的，如果找不到动物，该 API 可能会返回 404。但为了正确记录错误，我们需要访问动物所在的国家/地区。可能吗？我读过something from a guy called Stephen Cleary，这让我觉得 lambdas 是可能的，但我找不到任何东西。

var gettingNames = new List<Task<string>>();

foreach (var animal in animals)
{
    gettingNames.Add(this.zooApi.GetNameAsync(animal));
}

try
{
    await Task.WhenAll(gettingNames);
}
catch (Exception e)
{
    var exception = gettingNames.Where(task => task.IsFaulted)
        .SelectMany(x => x.Exception.InnerExceptions).First();

    this.logger.LogError("The animal name from {Country} was not found",
        animal.Country); // This is the goal
}

Answer 1

解决此问题的一种方法是将每个Animal 投影到Task，其中包含比裸名称或裸错误更多的信息。例如，您可以将其投影到包含三条信息的 Task<ValueTuple<Animal, string, Exception>>：动物、zooApi 中的动物学名，以及调用 zooApi.GetScientificNameAsync 方法时可能发生的错误。

执行此投影的最简单方法是 LINQ Select 运算符：

List<Task<(Animal, string, Exception)>> tasks = animals.Select(async animal =>
{
    try
    {
        return (animal, await this.zooApi.GetScientificNameAsync(animal),
            (Exception)null);
    }
    catch (Exception ex)
    {
        return (animal, null, ex);
    }
}).ToList();

(Animal, string, Exception)[] results = await Task.WhenAll(tasks);

foreach (var (animal, scientificName, error) in results)
{
    if (error != null)
        this.logger.LogError(error,
            $"The {animal.Name} from {animal.Country} was not found");
}

Answer 2

你几乎成功了。 :)

您需要Dictionary<Task<string>, string> 结构而不是List<Task<string>>：

static async Task Main()
{
    var taskInputMapping = new Dictionary<Task<string>, string>();
    var inputs = new[] { "input", "fault", "error", "test"};
    foreach (var input in inputs)
    {
        taskInputMapping.Add(DelayEcho(input), input);
    }

    try
    {
        await Task.WhenAll(taskInputMapping.Keys);
    }
    catch
    {
        foreach (var pair in taskInputMapping.Where(t => t.Key.IsFaulted))
        {
            Console.WriteLine($"{pair.Value}: {pair.Key.Exception?.GetType().Name}");
        }
    }
}

static readonly ImmutableArray<string> wrongInputs = 
    ImmutableArray.Create("error", "fault");
static async Task<string> DelayEcho(string input)
{
    if (wrongInputs.Contains(input)) throw new ArgumentException();
    await Task.Delay(10);
    return input;
}

• taskInputMapping.Add(DelayEcho(input), input)：将输入存储在任务本身旁边
• taskInputMapping.Where(t => t.Key.IsFaulted): 遍历出错的任务
• $"{pair.Value}: {pair.Key.Exception?.GetType().Name}"：检索输入+相关错误

Answer 3

我结合了答案并想出了这个：

var tasks = animals.Select(async animal =>
{
    try
    {
        return await this.zooApi.GetNameAsync(animal);
    }
    catch (Exception ex)
    {
        this.logger.LogError(error,
            $"The {animal.Name} from {animal.Country} was not found");

        return null;
    }
});

var results = await Task.WhenAll(tasks);

foreach (var name in results.Where(x => x != null))...