代码之家 › 专栏 › 技术社区 › neildt

task.waitall上的system.aggregateexception

aggregateexception task c#

neildt · 技术社区 · 5 年前

我有下面的代码,它正在触发一些异步任务。

        List<TimeoutException> TimeoutExceptions = new List<TimeoutException>();
        List<TaskCanceledException> TaskCanceledExceptions = new List<TaskCanceledException>();
        List<Exception> Exceptions = new List<Exception>();
        List<AggregateException> AggregateExceptions = new List<AggregateException>();

        List<Models.Channel.IChannel> channels = new List<Models.Channel.IChannel>();            
        channels.Add(new Models.Channel.DummyChannelName());            

        var tasks = new List<Task>();
        foreach (Models.Channel.IChannel channel in channels)
        {
            try
            {
                var cts = new CancellationTokenSource();                    
                cts.CancelAfter(channel.TimeOut);

                tasks.Add(Task.Run(() =>
                { 
                    channel.Data = channel.RequestOffers(new Models.Request.AvailabilityRequest()).Result;

                    if (cts.Token.IsCancellationRequested)                        
                        cts.Token.ThrowIfCancellationRequested();

                }, cts.Token));
            }
            catch (TimeoutException t)
            {
                TimeoutExceptions.Add(t);
            }
            catch (TaskCanceledException tc)
            {
                TaskCanceledExceptions.Add(tc);
            }
            catch (AggregateException ae)
            {
                AggregateExceptions.Add(ae);
            }
            catch(Exception ex)
            {
                Exceptions.Add(ex);
            }

        }

        Task.WaitAll(tasks.ToArray(), TimeSpan.FromSeconds(5));

我遇到的问题是,如果由于超时而取消任务,则会出现以下异常

<ExceptionMessage>One or more errors occurred.</ExceptionMessage>
<ExceptionType>System.AggregateException</ExceptionType>

只是一个简单的例子,我需要一个try-catch-around-task.waitall,或者我的代码应该有不同的结构。

1 回复 | 直到 5 年前

Pretasoc 5 年前

如果任务内部发生异常,则在调用线程上引发异常 Wait 为了一项任务。如果任务成功创建,则任务中发生的所有异常都将包装在 AggregateException 然后等待。

例如,这意味着您可以移除循环中的try/catch块,并使用它来包装 Task.WaitAll(...) 循环之后。

var tasks = new List<Task>();
foreach (Models.Channel.IChannel channel in channels)
{
    Task myTask = Task.Run(...); // create your task here
    tasks.Add(myTask);
}

try
{
    Task.WaitAll(tasks.ToArray(), TimeSpan.FromSeconds(5));
}
catch
{
    // Insert Exception handling logic
}

推荐文章

JasonC · 除了使用lambda函数,还有其他方法可以将参数输入到任务中吗?

2 年前

aspnetuser · 调用链中的异步等待分配

6 年前

Brian Rak · 如果没有对任务的引用,任务是否会被垃圾收集中断?

6 年前

paparazzo · 任务列表没有给出我所期望的

6 年前

paparazzo · 任务列表-开始,然后等待全部

6 年前

Craig · create\u async在UI线程上的行为如何?

6 年前

JuChom · 如何使用async/await处理潜在的大量任务?

6 年前

Craig · 我是否需要在单语言UWP应用程序中创建\u async?

6 年前

Gabriel Bernardone · 即使在发生异常后,任务也会持续执行

6 年前

Dan · 如何使用JavaFX中的后台工作在GUI中进行更改?

6 年前