System.Threading.Tasks.TaskExceptionHolder.Finalize() 处的 System.AggregateException

Question

更新：

添加 TaskCreationOptions.LongRunning 解决了这个问题，但这是一个好方法吗？如果没有，克服此异常的最佳解决方案是什么？

我正在尝试解决一个问题。我已经实施了 StackOverFlow 中提供的建议，但这些建议并没有帮助解决问题。我通过附加扩展方法使用了其他替代方法，例如 ContinuwWith 选项而不是 Task.WaitAll。这也无济于事。

我已经放了 Ex.handle { } 并且我尝试在异常中的 Catch(aggrgateException ex) 中抛出 ex，但这无助于捕获实际异常。

我只安装了 .Net 4.0，所以我无法尝试使用 .Net 4.5 分辨率来解决这个问题

我一直得到的例外是

"System.AggregateException:" 通过等待任务或访问异常属性未观察到任务异常"

在此之后它只是杀死工作进程并且应用程序崩溃并且我在 EventViewer 中看到一个条目

这里的任何帮助将不胜感激。

我们有以下代码：

Task<List<MyBusinessObject>>[] tasks = new Task<List<MyBusinessObject>>[MyCollection.Count];

for (int i = 0; i < MyCollection.Count; i++)
{
    MyDTO dto = new MyDTO();

     --Some Property Assignment for the MyDTO object--

    tasks[i] = Task<List<MyBusinessObject>>.Factory.StartNew(MyDelegate, dto)

}

try
{
    Task.WaitAll(tasks);
}
catch (AggregateException e)
{
    AddToLogFile("Exceptions thrown by WaitAll() : ");

    for (int j = 0; j < e.InnerExceptions.Count; j++)
    {
        AddToLogFile(e.InnerExceptions[j].ToString());

    }
}  
catch(Exception ex)

{  

AddToLogFile(ex.Message);

}

第二种选择

public Static Class Extensions
{
 public static void LogExceptions(this Task<List<<MyBusinessObject>> task)
        {
            task.ContinueWith(t =>
            {
                var aggException = t.Exception.Flatten();
                foreach (var exception in aggException.InnerExceptions)
                {
                    AddToLogFile("Task Exception: " + exception.Message);

                }
            },
            TaskContinuationOptions.OnlyOnFaulted);
        }
}
//In a different class call the extension method after starting the new tasks
Task<List<MyBusinessObject>>[] tasks = new Task<List<MyBusinessObject>>[MyCollection.Count];

for (int i = 0; i < MyCollection.Count; i++)
{
    MyDTO dto = new MyDTO();

     --Some Property Assignment for the MyDTO object--

    tasks[i] = Task<List<MyBusinessObject>>.Factory.StartNew(MyDelegate, dto).LogExceptions()

}

Answer 1

我没有一次为每个迭代创建一个新任务，而是每次为 100 个任务创建一个新任务。然后我等到所有的任务都完成了，然后又产生了 100 个任务，直到所有的任务都完成了

int count = Mycollection.Count(); 任务>[] 个任务；

        int i = 0;
                int j;
                while (i < count)
                {
                    j = 0;
                    tasks = new Task<List<MyBusinessObject>>[nbrOfTasks];
                    foreach (var p in Mycollection.Skip(i).Take(nbrOfTasks))
                    {
                        MyRequestDto dto = new MyRequestDto ();
                    --Some Proerty Assignment
                        tasks[j] = Task<List<MyBusinessObject>>.Factory.StartNew(MyDelegate, dto);
                        i++;
                        j++;
                    }

        try
                    {
                        // Wait for all the tasks to finish. 
                        if (tasks != null && tasks.Count() > 0)
                        {
                            tasks = tasks.Where(t => t != null).ToArray();
                            Task.WaitAll(tasks);
                        }
                    }
        catch (AggregateException e)
                    {
            }       

这与可用于服务多个任务的内存有关。如果所需的 RAM 在此过程中无法为并发任务提供服务，应用程序就会崩溃。这就是为什么最好生成有限的 nbr 个任务。而不是产生多个并将其留给线程池进行管理。