如何在任务完成时处理它们——但每个任务都需要不同的方法来处理任务的结果

本文关键字:任务 处理 结果 方法 完成时 | 更新日期: 2023-09-27 18:12:18

我使用async/await调用一些外部api。它们都返回一个字符串值,但格式不同,需要自己的处理。我想在任务完成时处理返回值。我不想等到所有的都完成,因此我使用Task.WhenAny()。我如何在任务完成时处理它们,并且在每个任务完成时仍然使用正确的"处理"方法?

我在我的第一篇文章之后做了一些改变,这是我最新的:

public async Task<List<string>> Get()
{
    var task1 = Method1Async();
    var task2 = Method1Async();
    var tasks = new List<Task<string>> {task1, task2};
    var results = new List<string>();
    while (tasks.Count > 0)
    {
        var justCompletedTask = await Task.WhenAny(tasks);//will not throw
        tasks.Remove(justCompletedTask);
        try
        {
           var result = await justCompletedTask;
           results.Add(result);
        }
        catch(Exception)
        { 
          //deal with it
        }
    }
    return results;
}
private async Task<string> Method1Async()
{
    //this may throw - something like forbidden or any other exception
    var task = _httpClient.GetStringAsync("api1's url here");
    var result = await Method1ResultProcessorAsync(task);
    return result;
}
private async Task<string> Method1ResultProcessorAsync(Task<string> task)
{
    //process task's result -if it successuflly completed and return that
    return await task; //for now
}
private async Task<string> Method2Async()
{
    //this may throw - something like forbidden or any other exception
    var task = _httpClient.GetStringAsync("api2's url here");
    var result = await Method2ResultProcessorAsync(task);
    return await task;
}
private async Task<string> Method2ResultProcessorAsync(Task<string> task)
{
    //This processing logic is entirely different from Method1ResultProcessor
    //process task's result -if it successfully completed and return that 
    return await task; //for now
}

我有两个问题:

  1. 这是解决问题的正确方法吗?
  2. 我如何更好地处理这里的异常?这是非常重要的,所以一个人的失败不应该使整个事情失败。只要其中任何一种方法成功,就没问题。但是,如果所有的失败,我想Get方法抛出。

如何在任务完成时处理它们——但每个任务都需要不同的方法来处理任务的结果

因为你的处理器方法已经接受了Task,你可以直接调用它们,它们将异步等待相应的结果:

public Task<string[]> Get()
{
    var task1 = Method1ResultProcessorAsync(Method1Async());
    var task2 = Method2ResultProcessorAsync(Method2Async());
    return Task.WhenAll(task1, task2);
}

你所描述的处理异常的方式会使它变得更复杂,但是你可以使用像这样的东西:

public async Task<List<string>> Get()
{
    var task1 = Method1ResultProcessorAsync(Method1Async());
    var task2 = Method2ResultProcessorAsync(Method2Async());
    var tasks = new[] { task1, task2 };
    try
    {
        await Task.WhenAll(tasks);
    }
    catch {}
    var results = tasks.Where(t => t.Status == TaskStatus.RanToCompletion)
                       .Select(t => t.Result)
                       .ToList();
    if (results.Any())
        return results;
    // or maybe another exception,
    // since await handles AggregateException in a weird way
    throw new AggregateException(tasks.Select(t => t.Exception));
}
  1. 这是描述Method1Async()Method2Async()的另一种方法。这是ContinueWith的演示。回答你在标题中问的问题-你可以为每个任务使用不同的方法,该方法将在任务完成后被称为

    var task1 = _httpClient.GetStringAsync("api1's url here").ContinueWith(t => Method1ResultProcessorAsync(t));
    var task2 = _httpClient.GetStringAsync("api2's url here").ContinueWith(t => Method2ResultProcessorAsync(t));
    
  2. 正确处理异常。回答"但是如果一切都失败了,我想要Get方法抛出。":检查results.Count == 0是否在return之前,throw是否为0。