zoukankan      html  css  js  c++  java
  • C# 多线程中CancellationToken(取消令牌)以及链式反应

    using System;
    using System.Net.Http;
    using System.Threading;
    using System.Threading.Channels;
    using System.Threading.Tasks;
     
    namespace ConsoleApp1
    {
        class Program
        {
            static async Task Main(string[] args)
            {
                await GetWeatherToday();
     
                await GetWeatherTest();
     
                Console.ReadKey();
            }
     
            public async static Task GetWeatherToday()
            {
                /*
                在某些场景中,我们需要请求外部的第三方资源,比如请求天气预报信息;但是,由于网络等原因,可能会造成长时间的等待以致业务超时退出,
                这种情况可以使用 CancellationToken 来进行优化,但请求超过指定时长后退出,而不必针对每个 HttpClient 进行单独的超时设置
                CancellationToken(取消令牌)
                */
                CancellationTokenSource cts = new CancellationTokenSource();
                cts.CancelAfter(3000);  //3秒后取消
                HttpClient client = new HttpClient();
                var res = await client.GetAsync("http://www.weather.com.cn/data/sk/101020100.html", cts.Token);
                var result = await res.Content.ReadAsStringAsync();
                Console.WriteLine(result);
                cts.Dispose();
                client.Dispose();
            }
     
     
            /// <summary>
            /// CancellationToken 的链式反应
            /// 可以使用创建一组令牌,通过链接各个令牌,使其建立通知关联,当 CancellationToken 链中的某个令牌收到取消通知的时候,
            /// 由链式中创建出来的 CancellationToken 令牌也将同时取消
            /// 代码定义了 3 个 CancellationTokenSource ,分别是 cts1,cts2,cts3,每个 CancellationTokenSource 分别注册了 Register 取消回调委托,
            /// 然后,使用 HttpClient 发起 3 组网络请求;其中,设置 cts2 在请求开始 1秒 后退出,
            /// 预期结果为:当 cts2 退出后,由于 cts3 是使用 CreateLinkedTokenSource(cts1.Token, cts2.Token) 创建出来的,所以 cts3 应该也会被取消,
            /// 实际上,无论 cts1/cts2 哪个令牌取消,cts3 都会被取消
            /// </summary>
            /// <returns></returns>
            public async static Task GetWeatherTest()
            {
                CancellationTokenSource cts1 = new CancellationTokenSource();
                CancellationTokenSource cts2 = new CancellationTokenSource();
                var cts3 = CancellationTokenSource.CreateLinkedTokenSource(cts1.Token, cts2.Token);
                //注册Register取消回调委托
                cts1.Token.Register(() =>
                {
                    Console.WriteLine("cts1 Canceling");
                });
                cts2.Token.Register(() =>
                {
                    Console.WriteLine("cts2 Canceling");
                });
                cts2.CancelAfter(1000); //1秒后取消
                cts3.Token.Register(() =>
                {
                    Console.WriteLine("cts3 Canceling");
                });
     
                var res = await new HttpClient().GetAsync("http://www.weather.com.cn/data/sk/101020100.html", cts1.Token);
                var result = await res.Content.ReadAsStringAsync();
                Console.WriteLine("cts1:{0}", result);
     
                var res2 = await new HttpClient().GetAsync("http://www.weather.com.cn/data/sk/101020100.html", cts2.Token);
                var result2 = await res2.Content.ReadAsStringAsync();
                Console.WriteLine("cts2:{0}", result2);
     
                var res3 = await new HttpClient().GetAsync("http://www.weather.com.cn/data/sk/101020100.html", cts3.Token);
                var result3 = await res2.Content.ReadAsStringAsync();
                Console.WriteLine("cts3:{0}", result3);
            }
        }
    }

    MSCL超级工具类库
    基于C#开发的超强工具类,包含数据库操作,字符串处理,文件或者文件夹处理
    网络请求,缓存处理,数据容器等上百个常用工具类封装,附带调用示例和参数说明,
    提供CHM详细文档,上百个生产环境使用,稳定高效,简单易用。
    真正做到“工具在手,一切尽有”,让你大幅度的提高编程效率,提高编程水平。
    联系QQ:7400799(请备注 "MSCL")

    ===============================================

    重要压缩文件忘记解压密码?网上下载rar/zip/7z等压缩文件,需要密码?
    ====极速解密助手,支持支持RAR/ZIP/7Z等多种压缩文档解密======
    ★ 解密不超过24小时,跟密码复杂程度相关
    ★ 解密成功后再收费,无套路
    ★ 解密成功后自动删除原件,无后顾之忧
    联系QQ:7400799(请备注 "文件解密")

    ==============================================

    Magic.Orm已在数百个成熟项目中应用,是比较完善的ORM框架(基于C#开发)。开发过程中参考了NBear与MySoft,吸取了其中的一些精华,加入新思想,
    后期参考EF的Lambda语法进行大量扩展。

    为什么选择Magic.Orm?

    • 上手简单,0学习成本。使用方便,按照sql书写习惯编写C#.NET代码。功能强大。
    • 高性能,接近手写Sql。
    • 体积小(不到200kb,仅一个dll)。
    • 完美支持Sql Server(2000至最新版),MySql,Oracle,Access,Sqlite等数据库。
    • 支持大量Lambda表达式写法。
    • 不需要像NHibernate的XML配置,不需要像EF的各种数据库连接驱动,集成简单。

    购买源码 请联系QQ:7400799(请备注 "ORM")

  • 相关阅读:
    sqli-labs(十七)
    sqli-labs(十六)(order by注入)
    sqli-labs(十五)(堆叠注入)
    spring boot热部署
    java之定时任务
    python之字符串函数
    java加载配置文件信息
    python之运算符与基本数据类型
    python基础
    python介绍
  • 原文地址:https://www.cnblogs.com/smartsmile/p/14415996.html
Copyright © 2011-2022 走看看