使用异步代码时获得有意义的堆栈跟踪

Question

我创建了一小段代码用于并行运行多个异步操作（Parallel 类本身不适用于异步操作）。

看起来像这样：

public static async Task ForEachAsync<T>(this IEnumerable<T> source, int dop, Func<T, Task> body)
{
    var chunks = source.Chunk(dop);
    foreach (var chunk in chunks)
        await Task.WhenAll(chunk.Select(async s => await body(s).ContinueWith(t => ThrowError(t))));
}

private static IEnumerable<IEnumerable<T>> Chunk<T>(this IEnumerable<T> source, int chunksize)
{
    while (source.Any())
    {
        yield return source.Take(chunksize);
        source = source.Skip(chunksize);
    }
}

private static void ThrowError(Task t)
{
    if (t.IsFaulted)
    {
        if (t.Exception.InnerExceptions != null && t.Exception.InnerExceptions.Count == 1)
            throw t.Exception.InnerExceptions[0];
        else
            throw t.Exception;
    }
}

就并行运行任务而言，上述代码运行良好。但是，当抛出异常时，我确实会遇到一些问题。

就返回异常消息而言，异常捕获代码运行良好，但堆栈跟踪还有很多不足之处 - 因为它指向 ThrowError 方法，而不是最初生成异常的方法。我可以按自己的方式工作并找出附加的调试器出了什么问题，但是如果我发布此应用程序，我将没有该选项可用 - 充其量，我会记录堆栈跟踪的异常。

那么 - 在运行异步任务时，有什么方法可以获得更有意义的堆栈跟踪？

PS。这是针对 WindowsRT 应用程序的，但我认为问题不仅限于 WindowsRT……

Answer 1

那么 - 在运行异步任务时，有什么方法可以获得更有意义的堆栈跟踪？

是的，您可以将 .NET 4.5 中引入的 ExceptionDispatchInfo.Capture 专门用于异步等待：

private static void ThrowError(Task t)
{
    if (t.IsFaulted)
    {
        Exception exception = 
            t.Exception.InnerExceptions != null && t.Exception.InnerExceptions.Count == 1 
                ? t.Exception.InnerExceptions[0] 
                : t.Exception;

        ExceptionDispatchInfo.Capture(exception).Throw();
    }
}

"您可以在另一个时间使用此方法返回的ExceptionDispatchInfo 对象，并可能在另一个线程上重新抛出指定的异常，就好像异常已经从捕获它的点流到它的点被重新抛出。 如果异常在被捕获时处于活动状态，则存储异常中包含的当前堆栈跟踪信息和 Watson 信息。如果处于非活动状态，即没有被抛出，则不会有任何堆栈跟踪信息或 Watson 信息。”

但是，请记住，异步代码中的异常通常没有您希望的那么有意义，因为所有异常都是从编译器生成的状态机上的 MoveNext 方法内部抛出的。

Answer 2

i3arnon 的回答是完全正确的，但仍有一些选择。您面临的问题是因为throw 是捕获堆栈跟踪的部分 - 通过再次抛出相同的异常，您已经丢弃了整个堆栈跟踪。

避免这种情况的最简单方法是让Task 完成它的工作：

t.GetAwaiter().GetResult();

就是这样 - 使用正确的堆栈跟踪和所有内容重新抛出异常。您甚至不必检查任务是否出错 - 如果是，它会抛出，如果不是，它不会。

在内部，此方法使用ExceptionDispatchInfo.Capture(exception).Throw(); i3arnon 显示，因此它们几乎等效（您的代码假定任务已经完成，无论是否出错 - 如果尚未完成，@ 987654325@ 将返回 false）。

Answer 3

上面的代码效果很好

我不确定您为什么希望将异常直接抛出到线程池 (ContinueWith)。这会使您的进程崩溃，而不会给任何代码清理机会。

对我来说，更自然的方法是让异常冒泡。除了允许自然清理之外，这种方法还删除了所有笨拙、怪异的代码：

public static async Task ForEachAsync<T>(this IEnumerable<T> source, int dop, Func<T, Task> body)
{
  var chunks = source.Chunk(dop);
  foreach (var chunk in chunks)
    await Task.WhenAll(chunk.Select(s => body(s)));
}

private static IEnumerable<IEnumerable<T>> Chunk<T>(this IEnumerable<T> source, int chunksize)
{
  while (source.Any())
  {
    yield return source.Take(chunksize);
    source = source.Skip(chunksize);
  }
}

// Note: No "ThrowError" at all.