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. 使用取消令牌.但是,如果您有机会检查他们的IsCancellationRequested财产,这才有意义.

您的代码将如下所示:

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.
}

但是,正如我所说,取消令牌只有在你能查看时才有意义.所以内部应该有机会GetAgeFromWebServiceX检查取消令牌并提前退出,否则,将令牌传递给这些方法是没有意义的.

Answer 2

好吧，您可以从操作中抛出异常，捕获AggregateException（GetPerson即在周围放置一个 try/catch 块Parallel.Invoke），检查它是否是正确类型的异常，然后返回 null。

除了停止所有线程之外，这满足了一切。我认为除非您开始使用取消令牌，否则您不太可能轻松停止已经运行的任务。您可以通过保留一个值来指示到目前为止boolean是否有任何任务失败，并让每个任务在开始之前进行检查来阻止进一步的任务执行......这有点难看，但它会起作用。

我怀疑使用“完整”任务而不是Parallel.Invoke会让所有这一切变得更加优雅。