如何在任务完成时处理它们——但每个任务都需要不同的方法来处理任务的结果
本文关键字:任务 处理 结果 方法 完成时 | 更新日期: 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
}
我有两个问题:
- 这是解决问题的正确方法吗?
- 我如何更好地处理这里的异常?这是非常重要的,所以一个人的失败不应该使整个事情失败。只要其中任何一种方法成功,就没问题。但是,如果所有的失败,我想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));
}
-
这是描述
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));
-
正确处理异常。回答"但是如果一切都失败了,我想要Get方法抛出。":检查
results.Count == 0
是否在return
之前,throw
是否为0。