28

我正在尝试抛出并捕获 AggregateException。我在 C# 上并没有非常多地使用异常，但我发现的行为有点令人惊讶。

我的代码是：

var numbers = Enumerable.Range(0, 20);

try
{
    var parallelResult = numbers.AsParallel()
        .Where(i => IsEven(i));
    parallelResult.ForAll(e => Console.WriteLine(e));

}
catch (AggregateException e)
{
    Console.WriteLine("There was {0} exceptions", e.InnerExceptions.Count());
}

它正在调用函数 IsEven

private static bool IsEven(int i)
{
    if (i % 10 == 0)
        throw new AggregateException("i");
    return i % 2 == 0;
}

这会引发 AggregateException。

我希望代码能写出 0,20 范围内的每个偶数，并且“有 1 个异常”两次。

我得到的是打印了一些数字（它们是 ForAll 的随机原因），然后抛出异常，但没有被捕获并且程序停止。

我错过了什么吗？

4

2 回答 2

26

这其实有点意思。我认为问题在于您AggregateException以一种意想不到的方式使用，这导致 PLINQ 代码中出现错误。

的全部要点AggregateException是将并行过程中可能同时（或几乎同时）发生的多个异常组合在一起。所以AggregateException预计至少会有一个内部异常。但是您正在 throwing new AggregateException("i")，它没有内部异常。PLINQ 代码尝试检查该InnerExceptions属性，遇到某种错误（可能是 a NullPointerException），然后它似乎进入某种循环。这可以说是 PLINQ 中的一个错误，因为您使用的是有效的构造函数 for AggregateException，即使它是一个不寻常的构造函数。

正如在别处所指出的，投掷ArgumentException在语义上会更正确。但是您可以通过抛出正确构造的 来获得您正在寻找的行为AggregateException，例如通过将IsEven函数更改为如下所示：

private static bool IsEven(int i)
{
    if (i % 10 == 0){
        //This is still weird
        //You shouldn't do this. Just throw the ArgumentException.
        throw new AggregateException(new ArgumentException("I hate multiples of 10"));
    }
    return i % 2 == 0;
}

我认为这个故事的寓意是不要扔AggregateException，除非你真的知道你在做什么，特别是如果你已经在某种并行或Task基于操作的操作中。

于 2013-10-15T21:20:00.497 回答
8

我同意其他人的观点：这是 .Net 中的一个错误，您应该报告它。

原因在于QueryEnd()内部类中的方法QueryTaskGroupState。它的反编译（并为清晰起见稍作修改）代码如下所示：

try
{
  this.m_rootTask.Wait();
}
catch (AggregateException ex)
{
  AggregateException aggregateException = ex.Flatten();
  bool cacellation = true;
  for (int i = 0; i < aggregateException.InnerExceptions.Count; ++i)
  {
    var canceledException =
        aggregateException.InnerExceptions[i] as OperationCanceledException;
    if (IsCancellation(canceledException))
    {
      cacellation = false;
      break;
    }
  }
  if (!cacellation)
    throw aggregateException;
}
finally
{
  this.m_rootTask.Dispose();
}
if (!this.m_cancellationState.MergedCancellationToken.IsCancellationRequested)
  return;
if (!this.m_cancellationState.TopLevelDisposedFlag.Value)
  CancellationState.ThrowWithStandardMessageIfCanceled(
    this.m_cancellationState.ExternalCancellationToken);
if (!userInitiatedDispose)
  throw new ObjectDisposedException(
    "enumerator", "The query enumerator has been disposed.");

基本上，它的作用是：

  • AggregateException如果包含任何非取消异常，则重新抛出展平
  • 如果请求取消，则抛出新的取消异常（或返回而不抛出，我不太了解那部分，但我认为这与这里无关）
  • else throwObjectDisposedException由于某种原因（假设userInitiatedDispose是false，它是）

所以，如果你抛出一个AggregateException没有内部异常的，ex将是一个AggregateException包含你的空的AggregateExcaption。调用Flatten()将把它变成一个空的AggreateException，这意味着它不包含任何非取消异常，所以代码的第一部分认为这是取消并且不抛出。

但是代码的第二部分意识到这不是取消，所以它抛出了一个完全虚假的异常。

于 2013-10-15T23:03:41.810 回答