3

我的 parallel.for 循环中出现“发生一个或多个错误”异常：

at System.Threading.Tasks.Task.ThrowIfExceptional(Boolean includeTaskCanceledExceptions)
at System.Threading.Tasks.Task.Wait(Int32 millisecondsTimeout, CancellationToken            cancellationToken)
at System.Threading.Tasks.Task.Wait()
at System.Threading.Tasks.Parallel.ForWorker[TLocal](Int32 fromInclusive, Int32 toExclusive, ParallelOptions parallelOptions, Action`1 body, Action`2 bodyWithState, Func`4 bodyWithLocal, Func`1 localInit, Action`1 localFinally)
at System.Threading.Tasks.Parallel.For(Int32 fromInclusive, Int32 toExclusive, ParallelOptions parallelOptions, Action`1 body)
at StaticClassLibrary.BLL.StaticClass.StatiMethod(String strExt, Object wTable, Object job, String BSPConnectionString) in c:\Users\FredWAD\Documents\Visual Studio 2010\Projects\PayrollCenterLibrary\BLL\ContributionFileManager.cs:line 218
   at myapp.staticlibrary.staticmethod(String str1, String str2)

该应用程序采用结构集合，每个对象都包含元数据，并将它们插入数据库。

违规代码如下：

Parallel.For(0, recordCnt, pOptions, d =>
               {
                   //flds = wTable.records[d].fields;
                   ssn = wTable.records[d].fields[fieldIndex].Value;
                   //rowId = wTable.records[d].fields[fieldIndex].rowId;
                   currentPerson = PersontManager.GetPerson(string1, string2);
                   hasContributions = WorkTableManager.RowHasContributionsNEW(List<string> lst, wTable.records[d]);
                   LoadRecordParallel(hasLoan, hasScratchpad, fieldIndex, wTable.records[d], object, string, string);
               }
           );

wTable = 集合对象。

记录 = 包含元数据的结构列表

fields = 每条记录中的结构。每条记录都包含这些列表。

这本质上是一个表，其中包含一行结构（其中还包含有关每行的一些元数据）和单元格结构。此错误似乎是随机发生的。我在这里做错了什么？

4

2 回答 2

4

您需要查看 AggregateException 上的 InnerExceptions 属性。这是 TPL 的默认行为，因为多个线程可能同时抛出异常。

有关详细信息，请参阅http://msdn.microsoft.com/en-us/library/system.aggregateexception.aspx。

我的猜测是您有某种类型的资源不是线程安全的；当并行线程正在访问它时，该资源会与另一个线程进入竞争状态，从而导致您的异常。第一个任务是找出你的并行查询的哪一行导致了问题，然后进入那个问题。如果您的数据库级别的行锁不够，它可能与数据库有关。

于 2012-10-19T21:54:06.970 回答
0

处理此问题的一种方法是try catch在 Parallel 循环中放置一个块。如果可以在循环内处理异常，则它不会以AggregateException.

于 2014-07-23T16:21:03.340 回答