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

前端之家收集整理的这篇文章主要介绍了c#-4.0 – Parallel.Invoke – 异常处理前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。
我的代码运行4个函数来填充信息(使用Invoke)到类,例如:
  1. class Person
  2. {
  3. int Age;
  4. string name;
  5. long ID;
  6. bool isVegeterian
  7.  
  8. public static Person GetPerson(int LocalID)
  9. {
  10. Person person;
  11. Parallel.Invoke(() => {GetAgeFromWebServiceX(person)},() => {GetNameFromWebServiceY(person)},() => {GetIDFromWebServiceZ(person)},() =>
  12. {
  13. // connect to my database and get information if vegeterian (using LocalID)
  14. ....
  15. if (!person.isVegetrian)
  16. return null
  17. ....
  18. });
  19. }
  20. }

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

解决方法

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

>安排检测是否要提前退出的操作作为第一个操作.它会更快地安排(可能是第一次,但不保证)所以你很快就会知道是否要退出.
>当您检测到错误并在Jon的答案指示时捕获AggregateException时抛出异常.
>使用取消令牌.但是,如果您有机会检查他们的IsCancellationRequested财产,这才有意义.

您的代码将如下所示:

  1. var cts = new CancellationTokenSource();
  2. try
  3. {
  4. Parallel.Invoke(
  5. new ParallelOptions { CancellationToken = cts.Token },() =>
  6. {
  7. if (!person.IsVegetarian)
  8. {
  9. cts.Cancel();
  10. throw new PersonIsNotVegetarianException();
  11. }
  12. },() => { GetAgeFromWebServiceX(person,cts.Token) },() => { GetNameFromWebServiceY(person,() => { GetIDFromWebServiceZ(person,cts.Token) }
  13. );
  14. }
  15. catch (AggregateException e)
  16. {
  17. var cause = e.InnerExceptions[0];
  18. // Check if cause is a PersonIsNotVegetarianException.
  19. }

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

猜你在找的C#相关文章