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，这种方式不会中断循环，应该处理所有行。