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

发布时间：2020-12-15 06:25:29 所属栏目：百科来源：网络整理

导读：我的代码运行4个函数来填充信息(使用Invoke)到类,例如： class Person{ int Age; string name; long ID; bool isVegeterian public static Person GetPerson(int LocalID) { Person person; Parallel.Invoke(() = {GetAgeFromWebServiceX(person)},() = {Get

我的代码运行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.如何实现？

解决方法

要尽早退出Parallel.Invoke,您必须做三件事：

>安排检测是否要提前退出的操作作为第一个操作.它会更快地安排(可能是第一次,但不保证)所以你很快就会知道是否要退出.
>当您检测到错误并在Jon的答案指示时捕获AggregateException时抛出异常.
>使用取消令牌.但是,如果您有机会检查他们的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,() => { GetIDFromWebServiceZ(person,cts.Token) }
    );
}
catch (AggregateException e)
{
    var cause = e.InnerExceptions[0];
    // Check if cause is a PersonIsNotVegetarianException.
}

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

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!