zoukankan      html  css  js  c++  java
  • c# Task编程一个task抛出异常后怎么取消其他线程

    从MSDN的Forum上看到别人提供的解决方案,感觉还是比较靠谱,所以就保存下来。

                CancellationTokenSource cts = new CancellationTokenSource();

                Task t1 = Task.Factory.StartNew(() =>

                {

                    if (!cts.IsCancellationRequested)

                    {

                        try

                        {

                            //task body that may throw

                            Console.WriteLine("Task1");

                        }

                        catch

                        {

                            cts.Cancel();

                            throw new OperationCanceledException(cts.Token); //the task final state will be Cancelled

           //the exception can be ignored if needed

                        }

     

                        if (cts.IsCancellationRequested)

                        {

                            //depending on the scenario

                            //ignore any computed result, do not persist any data, revert all changes

                        }

                    }

                }, cts.Token);

     

                Task t2 = Task.Factory.StartNew(() =>

                {

                    if (!cts.IsCancellationRequested)

                    {

                        try

                        {

                            //task body that may throw

                            Console.WriteLine("Task2");

                        }

                        catch

                        {

                            cts.Cancel();

                            throw new OperationCanceledException(cts.Token); //the task final state will be Cancelled

                        }

     

                        if (cts.IsCancellationRequested)

                        {

                            //depending on the scenario

                            //ignore any computed result, do not persist any data, revert all changes

                        }

                    }

                }, cts.Token);

     

    2.       In case that you would like to avoid try/catch in every body you could use a Task Continuation approach like below. However with this approach, the application will pay the price of new tasks being created. At the same time the Cancellation will be delayed.

                CancellationTokenSource cts = new CancellationTokenSource();

                Task t1 = Task.Factory.StartNew(() =>

                {

                    if (!cts.IsCancellationRequested)

                    {

                        //task body that may throw

                        Console.WriteLine("Task1");

                        if (cts.IsCancellationRequested)

                        {

                            //depending on the scenario

                            //ignore any computed result, do not persist any data, revert all changes

                        }

                    }

                }, cts.Token).ContinueWith((task) =>

                {

                    cts.Cancel();

                    //observe the exception

                    Exception ex = task.Exception;

                }, TaskContinuationOptions.OnlyOnFaulted|TaskContinuationOptions.ExecuteSynchronously );

     

                Task t2 = Task.Factory.StartNew(() =>

                {

                    if (!cts.IsCancellationRequested)

                    {

                        //task body that may throw

                        Console.WriteLine("Task2");

                        if (cts.IsCancellationRequested)

                        {

                            //depending on the scenario

                            //ignore any computed result, do not persist any data, revert all changes

                        }

                    }

                }, cts.Token).ContinueWith((task) =>

                {

                    cts.Cancel();

                    //observe the exception

                    Exception ex = task.Exception;

                }, TaskContinuationOptions.OnlyOnFaulted | TaskContinuationOptions.ExecuteSynchronously);

     

    参考,转载:

    https://social.msdn.microsoft.com/Forums/vstudio/en-US/2cbe1fa7-c7dd-4e88-8773-2e3bb1665e2e/how-to-cancel-other-task-when-there-is-an-exception-in-one-of-the-task?forum=parallelextensions

  • 相关阅读:
    【分布式】SpringCloud(2)--SpringCloud分布式架构思想的理解
    【分布式】SpringCloud(1)--基于RestTemplate构建简易微服务调用框架
    【问题管理】-- MyBatis实体类的属性名和数据库列名不一致解决方法汇总
    【开发工具】-- 一文全面解析 Postman 工具
    【数据库】Redis(4)--Redis进阶Redis配置与持久化
    【数据库】Redis(3)--Redis事务、Jedis、SpringBoot整合Redis
    分享的面试问题,java学习教程
    怎么保证缓存和数据库一致性
    详解一条 SQL 的执行过程
    json字符串{"1-3": 29},{"8-": 50},{"8-": 50},返回 1-3天 29,大于8天 100
  • 原文地址:https://www.cnblogs.com/yy3b2007com/p/4145845.html
Copyright © 2011-2022 走看看