c#-4.0 - Parallel.Invoke - 异常处理

Question

我的代码运行 4 个函数来向类填充信息(使用 Invoke)，例如:

class Person
{
    int Age;
    string name;
    long ID;
    bool isVegeterian

    public static Person GetPerson(int LocalID)
    {
        Person person;
        Parallel.Invoke(() => {GetAgeFromWebServiceX(person)}, 
                        () => {GetNameFromWebServiceY(person)},
                        () => {GetIDFromWebServiceZ(person)},
                        () => 
                        {
                           // connect to my database and get information if vegeterian (using LocalID)
                           ....
                           if (!person.isVegetrian)
                               return null
                           ....
                        });
     }
}

我的问题是:如果他不是素食主义者，我不能返回 null，但我希望能够停止所有线程，停止处理并只返回 null。如何实现？

Answer 1

要尽早退出 Parallel.Invoke，您必须做三件事:

1. 将检测是否要提前退出的操作安排为第一个操作。然后会更早安排(也许是第一个，但这不能保证)，这样您就会更快知道是否要退出。
2. 当您检测到错误并捕获 AggregateException 时抛出异常，如 Jon 的回答所示。
3. 使用取消 token 。然而，只有当您有机会检查他们的 IsCancellationRequested 时，这才有意义。属性(property)。

您的代码将如下所示:

var cts = new CancellationTokenSource();
try
{
    Parallel.Invoke(
        new ParallelOptions { CancellationToken = cts.Token },
        () =>
        {
            if (!person.IsVegetarian)
            {
                cts.Cancel();
                throw new PersonIsNotVegetarianException();
            }
        },
        () => { GetAgeFromWebServiceX(person, cts.Token) }, 
        () => { GetNameFromWebServiceY(person, cts.Token) },
        () => { GetIDFromWebServiceZ(person, cts.Token) }
    );
}
catch (AggregateException e)
{
    var cause = e.InnerExceptions[0];
    // Check if cause is a PersonIsNotVegetarianException.
}

但是，正如我所说，取消 token 只有在您可以检查时才有意义。因此，GetAgeFromWebServiceX 内部应该有机会检查取消 token 并提前退出，否则，将 token 传递给这些方法是没有意义的。