TPL中的异常处理

Question

我正在使用下面的代码来创建一些文件。

我观察到有时候如果一些异常发生在所有的Parallel.For线程之间停止。

我有几个问题。

1. 我应该在CreateReport方法或其@rt位置使用AggregateException。

2. 如何确保在任何线程中出现异常时，不会阻止其他并行线程。

Try 
      dtScheduledReports = objReprotHelper.GetTopImmediateReportsForExecution() 

     Parallel.For(0, dtScheduledReports.Rows.Count, Sub(i) 
                  CreateReport(dtScheduledReports.Rows(i)) 
                 End Sub) 
    Catch ae As AggregateException 
     For Each ex As Exception In ae.InnerExceptions 
      ExceptionHandler.LogError(ex) 
     Next 
    End Try 

Private Sub CreateReport(dtRow As DataRow, scheduleType As Integer) 
     Try 
       //do something 
     Catch 
       throw 
     End Try 
    End Sub 

Answer 1

可以使用ConcurrentQueue(Of Exception)启用安全例外，从多个线程进行排队。这允许执行整个循环并抛出AggregateException中的所有异常。

Private Sub DoAParalelJobAndThrowErrors 

    Dim exQueue as New ConcurrentQueue(Of Exception) 
    dtScheduledReports = objReprotHelper.GetTopImmediateReportsForExecution() 
    // Execute the complete loop and capture all exceptions. 
    Parallel.For(0, dtScheduledReports.Rows.Count, Sub(i) 
                 Try 
                 CreateReport(dtScheduledReports.Rows(i)) 
                 Catch ex as Exception 
                 exQueue.Enqueue(ex) 
                 End Try 
                End Sub) 

    If exQueue.count > 0 throw new AggregateException(exQueue) 

End Sub 

Private Sub CreateReport(dtRow As DataRow, scheduleType As Integer)  
    //do something 
End Sub 

根据MSDN这种方式不会打破循环，所有的行都应该被处理。