如何在 Parallel.Invoke 中管理异常？

Question

我有以下情况：

foreach(var item in collection)
{
    DoWork().Wait;
}

如您所见，有一个迭代集合的 foreach，对于每个调用，我需要等待 DoWork 完成执行，然后 foreach 可以继续。

问题是在DoWork 内部我正在使用Parallel 并且我得到一个“冻结”程序的异常，特别是没有显示任何异常，这是我的实现：

public async Task DoWork()
{
    Try
    {
        Parallel.Invoke(
               () => Foo(),
               () => Foo2(),
               () => Foo3());
    }
    catch(Exception e)
    {
       //No exception caught
    }
}

我在Foo方法里面加了一个Console.WriteLine比如：

public void Foo()
{
    Console.WriteLine("foo 1");
}

在Foo2 方法内部生成了一个异常，但我看不到是哪个异常，因为我在catch 上设置了一个断点，而这并没有触发。

我做错了什么？

Answer 1

1. 您的 DoWork() 方法不会异步运行，因为它缺少任何调用 到await。
2. 当我尝试使用您的代码的可编译版本时，我确实看到了异常。

无论如何，如果您想让DoWork() 正确异步，您需要使用Task.Run() 和await Task.WhenAll()，如下所示：

using System;
using System.Threading;
using System.Threading.Tasks;                                                    

namespace Demo
{
    class Program
    {
        public static async Task Main()
        {
            Console.WriteLine("Awaiting DoWork()");
            await DoWork();
            Console.WriteLine("Finished awaiting. Press <RETURN> to exit.");
            Console.ReadLine();
        }

        public static async Task DoWork()
        {
            try
            {
                await Task.WhenAll(
                    Task.Run(() => Foo()),
                    Task.Run(() => Foo2()),
                    Task.Run(() => Foo3())
                );
            }

            catch (Exception e)
            {
                Console.WriteLine("Caught exception: " + e.Message);
            }
        }

        public static void Foo()
        {
            Console.WriteLine("Starting Foo()");
            Thread.Sleep(1000);
            Console.WriteLine("Finishing Foo()");
        }

        public static void Foo2()
        {
            Console.WriteLine("Starting Foo2()");
            Thread.Sleep(500);
            Console.WriteLine("Foo2() is throwing an exception.");
            throw new InvalidOperationException("OOPS!");
        }

        public static void Foo3()
        {
            Console.WriteLine("Starting Foo3()");
            Thread.Sleep(250);
            Console.WriteLine("Finishing Foo3()");
        }
    }
}

如果您编译并运行该代码，您将看到以下消息：

waiting DoWork()
Starting Foo()
Starting Foo2()
Starting Foo3()
Finishing Foo3()
Foo2() is throwing an exception.
Finishing Foo()
Caught exception: OOPS!
Finished awaiting. Press <RETURN> to exit.

请记住，此答案仅适用于 C# 7.1 或更高版本 Async Main