C＃Parallel foreach - System.AggregateException：发生一个或多个错误。 ---> [英] C# Parallel foreach - System.AggregateException: One or more errors occurred. --->

问题描述

我有一个混淆了很长时间的错误，仍然无法修复它。任何人都可以帮忙吗？

I got one bug confused me long time,still not fix it.Anyone can help ?

private string ppcManageShortSales(string strData)
       {
List<salesresultppc> listSalesResultPPC = new List<salesresultppc>();
                            string[] arrSalesInfo = salesInfo.Split('`');
                            var sales = new salesInfoPPC[arrSalesInfo.Length];
                            string[] arrRawData = new string[arrSalesInfo.Length];//luo add Aug 28,2013
                            int taskIndex = 0;
                            for (int tt = 0; tt < arrSalesInfo.Length; tt++)
                            {
                                salesInfoPPC sippc = new salesInfoPPC();
                                sippc.strDataResource = strDataResouce;
                                sippc.payout = payout;
                                sippc.dtSalesDetail = createSalesDetailTable();
                                sippc.drawdate = arrSelectedDrawDate[0];
                                sippc.listHotDigit = listHotDigit;
                                sippc.salesInfo = arrSalesInfo[tt];
                                sippc.tempPlayMethodArrangeId = tempPlayMethodArrangeId;
                                sippc.salesIndex = tt;//luo add Aug 28,2013
                                sales[taskIndex] = sippc;
                                taskIndex++;
                            }
Parallel.ForEach(sales, (salesInfoPPC) => listSalesResultPPC.Add(ppcManageShortSalesHelper(salesInfoPPC)));

                   foreach (var result in listSalesResultPPC)
                           {
                               if (result.effect.Equals(0))
                               {
                                   effect = result.effect;
                                   strMessage = result.strMessage;
                                   total_amount += result.GrandTotal;
                                   dtSalesDetail.Merge(result.subSalesDetail);
                                   dtSumExcessDigit.Merge(result.subSumExcessDigit);
                                   dtSumHotDigit.Merge(result.subSumHotDigit);
                                   dtSumHotDigitAgent.Merge(result.subSumHotDigitAgent);
                                   hot_updateSql.Append(result.strSumHotDigitUpdateSql);
                                   updateSql.Append(result.strSumExcessDigitUpdateSql);
                                   //sbRawData.Append(result.RawValue);//old
                                   arrRawData[result.salesIndex] = result.RawValue;//luo add Aug 28,2013
                                   if (!intExistForceInsert.Equals(1))
                                       intExistForceInsert = result.intExistForceInsert;
                                   if (customerBalance.Equals(0))
                                       customerBalance = result.customerBalance;
                                   if (custId.Equals(0))
                                       custId = result.custId;
                                   customerName = result.customer;
                               }
                               else
                               {
                                   effect = result.effect;
                                   strMessage = result.strMessage;
                                   break;
                                   //intExistForceInsert = result.intExistForceInsert;
                               }
                           }

if (Main.ctsDetail.IsCancellationRequested)
                                    {
                                        Main.countTaskRunTimesDetail = 0;
                                        Main.ctsDetail = new CancellationTokenSource();
                                        Task.Factory.StartNew(ProcessQueueDetail, Main.ctsDetail.Token);
                                    }
                                    if (Main.detailQueue == null)
                                        Main.detailQueue = new Queue<datatable>();
                                    Main.detailQueue.Enqueue(dtSalesDetail);//dtSalesDetail add to the detailQueue,waiting for ProcessQueueDetail()method deal

                                    #region summary hot & excess digit tasks
                                    if (dtSumHotDigit.Rows.Count > 0)
                                        Task_InsertSummaryHotDigit(dtSumHotDigit);

                                    if (dtSumHotDigitAgent.Rows.Count > 0)
                                        Task_InsertSummaryHotDigitAgent(dtSumHotDigitAgent);

                                    Task task3 = null;//this one is ok
                                    ctsExcessDigitInsert = new CancellationTokenSource();
                                    if (dtSumExcessDigit.Rows.Count > 0)
                                        task3 = Task.Factory.StartNew(() => Task_InsertSummaryExcessDigit(dtSumExcessDigit), ctsExcessDigitInsert.Token);

                                    if (hot_updateSql.ToString().Length > 0)
                                        Task_UpdateSummaryHotDigit(hot_updateSql.ToString());

                                    ctsExcessDigitUpdate = new CancellationTokenSource();
                                    Task task5 = null;//this one is ok
                                    if (updateSql.ToString().Length > 0)
                                        task5 = Task.Factory.StartNew(() => Task_UpdateSummaryExcessDigit(updateSql.ToString()), ctsExcessDigitUpdate.Token);
                                    #endregion
}

private salesResultPPC ppcManageShortSalesHelper(salesInfoPPC salesInfoppc)
{
return new salesResultPPC{}
}

目前有5位用户使用这项服务，所以任何人都可以提供帮助？

等待你。

thx。

Current have 5 users use this service,so anyone can help?
waiting for u.
thx.

推荐答案

你好



AggregateException 是一个异常，包含在所有线程上抛出的所有个别异常。



所以基本上出了问题，一个或多个线程和一些异常被抛出在

Hello

AggregateException is an exception that contains all the individual exceptions thrown on all threads.

So basically something went wrong one or several threads and some exceptions were thrown in

Parallel.ForEach(sales, (salesInfoPPC) => listSalesResultPPC.Add(ppcManageShortSalesHelper(salesInfoPPC)));

You可以捕获 AggregateException 并使用它的 Handle 方法来了解问题所在。

You can catch the AggregateException and use it's Handle method to know what the problem was.

catch (AggregateException ae) {
    ae.Handle((x) =>
    {
        if (x is ArgumentNullException)
        {
           // manage the exception.
           return true; // do not stop the program
        }
        else if (x is UnauthorizedAccessException) 
        {
            // manage the access error.
            return true;
        }
        // else if any other exceptin type you want to handle. etc...

        else is (Exception ex)
        {
            // Any other exception here
        }
        return false; // Let anything else stop the application.
    });
}

Valery。

Valery.

这篇关于C＃Parallel foreach - System.AggregateException：发生一个或多个错误。 --->的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！