备案控制台
探索云世界
开发者社区 开发与运维 文章 正文

《CLR Via C# 第3版》笔记之（二十一） - 异步编程模型(APM)

2017-11-12 1522
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云拨测，每月3000次拨测额度
简介：

APM是.NET中异步编程模型的缩写（Asynchronous Programing Model）。

通过异步编程，使得我们的程序可以更加高效的利用系统资源。

主要内容：

  • 一个APM的例子
  • GUI中的APM
  • APM的优劣点
  • AMP使用中的注意事项 

1. 一个APM的例子

.Net中的异步模型非常完善，只要看到Begin***者End***方法。基本都是相对***方法的异步调用方式。

（注：***是方法的名称）

所以在.Net中实现一个异步调用是很方便的，下面用个小例子来演示一个异步操作。

首先是同步的方式请求百度搜索10次。(分别搜索1，2，3。。。。10）

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
public  class  CLRviaCSharp_21
{
     static  void  Main( string [] args)
     {
         // 用百度分别检索1，2，3。。。9，共检索10次
         DateTime start = DateTime.Now;
         string  strReq = "http://www.baidu.com/s?wd={0}" ;
         for  ( int  i = 0; i < 10; i++)
         {
             var  req = WebRequest.Create( string .Format(strReq, i));
             // 注意这里的GetResponse是同步方法
             var  res = req.GetResponse();
 
             Console.WriteLine( "检索 {0} 的结果已经返回！" , i);
 
             res.Close();
         }
 
         Console.WriteLine( "耗用时间：{0}毫秒" , TimeSpan.FromTicks(DateTime.Now.Ticks - start.Ticks).TotalMilliseconds);
         Console.ReadKey( true );
     }
}

结果如下：总共消耗时间33秒多。

image

 

异步的方式如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
public  class  CLRviaCSharp_21
{
     static  DateTime start;
     static  void  Main( string [] args)
     {
         // 用百度分别检索1，2，3。。。9，共检索10次
         start = DateTime.Now;
         string  strReq = "http://www.baidu.com/s?wd={0}" ;
         for  ( int  i = 0; i < 10; i++)
         {
             var  req = WebRequest.Create( string .Format(strReq, i));
             // 注意这里的BeginGetResponse就是异步方法
             var  res = req.BeginGetResponse(ProcessWebResponse, req);
         }
 
         Console.ReadKey( true );
     }
 
     private  static  void  ProcessWebResponse(IAsyncResult result)
     {
         var  req = (WebRequest)result.AsyncState;
         string  strReq = req.RequestUri.AbsoluteUri;
         using  ( var  res = req.EndGetResponse(result))
         {
             Console.Write( "检索 {0} 的结果已经返回！\t" , strReq.Substring(strReq.Length - 1));
             Console.WriteLine( "耗用时间：{0}毫秒" , TimeSpan.FromTicks(DateTime.Now.Ticks - start.Ticks).TotalMilliseconds);
         }
     }
 
}

结果如下：总共消耗的时间应该是下面所有时间中最长的那个，即9.5秒左右。

image

 

2. GUI中的APM

异步编程除了在服务端会大量应用，在有GUI的客户端也应用比较多（为了保证客户端的界面不会假死）。

但是Winform或WPF程序中，改变界面元素状态只有通过UI线程，其他线程如果试图改变UI元素，就会抛出异常(System.InvalidOperationException)。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
using  System;
using  System.Windows.Forms;
using  System.Net;
 
public  class  CLRviaCSharp_21
{
     static  void  Main( string [] args)
     {
         MyWindowsForm mf = new  MyWindowsForm();
         mf.ShowDialog();
     }
}
 
internal  class  MyWindowsForm : Form
{
     public  MyWindowsForm()
     {
         Text = "Click in the window to start a web request" ;
         Width = 800;
         Height = 600;
     }
 
     protected  override  void  OnMouseClick(MouseEventArgs e)
     {
         // 开始异步web请求
         Text = "web request initilized" ;
         var  webreq = WebRequest.Create( "http://www.baidu.com" );
         webreq.BeginGetResponse(ProcessWebResponse, webreq);
         base .OnMouseClick(e);
     }
 
     private  void  ProcessWebResponse(IAsyncResult result)
     {
         var  req = (WebRequest)result.AsyncState;
         using  ( var  res = req.EndGetResponse(result))
         {
             // SynchronizationContext.Current.Post(updateUI, res);
             // 这里改变UI元素Form的Text属性,抛出了异常
             Text = "Content length: "  + res.ContentLength;
         }
     }
}

那么其他线程如何改变UI元素呢。为了保证UI始终有响应，必须能够让其他线程也能改变UI元素。

答案就在上面代码中抛异常的上面一句代码。利用SynchronizationContext的Current属性来获取UI线程的同步上下文信息。

然后调用其Post方法，异步的更新UI元素。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
using  System;
using  System.Windows.Forms;
using  System.Net;
using  System.Threading;
 
public  class  CLRviaCSharp_21
{
     static  void  Main( string [] args)
     {
         MyWindowsForm mf = new  MyWindowsForm();
         mf.ShowDialog();
     }
}
 
internal  class  MyWindowsForm : Form
{
     public  MyWindowsForm()
     {
         Text = "Click in the window to start a web request" ;
         Width = 800;
         Height = 600;
     }
 
     protected  override  void  OnMouseClick(MouseEventArgs e)
     {
         // 开始异步web请求
         Text = "web request initilized" ;
         var  webreq = WebRequest.Create( "http://www.baidu.com" );
         webreq.BeginGetResponse(ProcessWebResponse, webreq);
         base .OnMouseClick(e);
     }
 
     private  void  ProcessWebResponse(IAsyncResult result)
     {
         var  req = (WebRequest)result.AsyncState;
         using  ( var  res = req.EndGetResponse(result))
         {
             SynchronizationContext.Current.Post(updateUI, res);
         }
     }
 
     private  void  updateUI( object  state)
     {
         var  res = (WebResponse)state;
         // 这里改变UI元素Form的Text属性, updateUI这个函数是由UI线程执行的
         Text = "Content length: "  + res.ContentLength;
     }
}

这样的实现看着很繁琐，所以《CLR via C#》作者Jeffrey实现了一个小方法（SyncContextCallback）来简化这个步骤。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
using  System;
using  System.Windows.Forms;
using  System.Net;
using  System.Threading;
 
public  class  CLRviaCSharp_21
{
     static  void  Main( string [] args)
     {
         MyWindowsForm mf = new  MyWindowsForm();
         mf.ShowDialog();
     }
}
 
internal  class  MyWindowsForm : Form
{
     public  MyWindowsForm()
     {
         Text = "Click in the window to start a web request" ;
         Width = 800;
         Height = 600;
     }
 
     protected  override  void  OnMouseClick(MouseEventArgs e)
     {
         // 开始异步web请求
         Text = "web request initilized" ;
         var  webreq = WebRequest.Create( "http://www.baidu.com" );
         webreq.BeginGetResponse(SyncContextCallback(ProcessWebResponse), webreq);
         base .OnMouseClick(e);
     }
 
     private  void  ProcessWebResponse(IAsyncResult result)
     {
         var  req = (WebRequest)result.AsyncState;
         using  ( var  res = req.EndGetResponse(result))
         {
             // 这里改变UI元素Form的Text属性,
             // 这次是在UI线程执行的，SyncContextCallback中获取了UI线程的同步上下文，
             // 然后用Post方法调用了ProcessWebResponse函数
             Text = "Content length: "  + res.ContentLength;
         }
     }
 
     // 大牛Jeffrey实现的SyncContextCallback方法
     private  static  AsyncCallback SyncContextCallback(AsyncCallback callback)
     {
         SynchronizationContext sc = SynchronizationContext.Current;
         // 如果没有同步上下文，直接返回传入的东西
         if  (sc == null ) return  callback;
 
         // 返回一个委托，这个委托将委托Post到捕捉到的SC中
         return  asyncResult => sc.Post(result => callback((IAsyncResult)result), asyncResult);
     }
}

 

3. APM的优劣点

上面两个例子，可以看出APM的一些优势，第一个例子说明异步的效率高。第二个GUI的例子说明异步可以增强用户体验。

其实APM的优势总结起来有以下几点：

  1. 资源利用率底(比如I/O并发读写时，线程不必等I/O完了就可以处理其他请求。这样几个线程就可以处理大量请求)
  2. 垃圾回收快(线程不用等待请求的操作完成就回线程池等待了，这时的线程在它们的栈顶，垃圾回收时遍历线程查找根比较快)
  3. 线程少，调试快(调试时，一旦遇到断点就会挂起所有线程。异步可以保证线程尽量少，所以调试时感觉会快)
  4. 使得GUI一直保持响应(上面的GUI例子可以说明)
  5. 并发执行下载，速度快(上面第一个例子可以说明)

当然，任何技术都不是完美的，有其适用的一面，也有其不适用的一面。

了解它的缺点，有时候甚至可以帮助我们更好的使用它。

APM的劣势主要有以下几点：

  1. 必须将代码分成多个回调方法(执行流程不直观)
  2. 避免使用实参和局部变量(实参和局部变量在回调方法中无法访问，记住回调方法在另一个线程中)
  3. 许多C#构造无法使用，比如try/catch/finally，using等(因为没法在一个方法中开始try，再在它的回调方法中完成finally)
  4. 有些功能很难实现，比如多个并发操作协作进行，取消和超时(比如上面例子中的更新GUI元素也很麻烦)

 

4. AMP使用中的注意事项

使用APM时以下几点需要注意：

  1. 不要提早调用End***方法，在回调函数中再调用End***(如果提早调用，异步操作没有完成，End***会一直等待，此时相当于同步调用)
  2. 调用End***且仅调用一次(异步操作初始化时分配的某些资源，必须调用End***才能释放。第二次调用End***时结果不可预测)
  3. 使用相同的对象调用Begin***方法和End***方法
  4. 在Begin***方法和End***方法中使用ref，out，params标记时需要注意(具体实现方法以后有空再补些例子:))
  5. 不能取消异步I/O操作(启动I/O操作后，控制权交给了I/O相关硬件)
  6. Begin***方法返回引用类型，无法返回值类型
  7. 用于打开文件的Win32 API(CreateFile)暂时没有异步的版本
  8. FileStream类在创建时就决定了是异步还是同步的方式(创建式指定异步标记，即使调用Read，也是通过Sleep来模拟同步。同样，指定了同步标记，调用BeginRead也是模拟的异步)
标签:  CLR via C#笔记



本文转自wang_yb博客园博客，原文链接：http://www.cnblogs.com/wang_yb/archive/2011/11/29/2267790.html，如需转载请自行联系原作者

文章标签：
应用实时监控服务
C#
Web App开发
.NET
Java
关键词：
C#笔记
C#异步编程
clrviac#第3版应用实时监控服务
异步编程模型应用实时监控服务
zting科技
目录
相关文章
jcLee95
|
3月前
|
C# Python
C# 笔记1 - 操作目录
C# 笔记1 - 操作目录
jcLee95
29 0
1941623231718325
|
3月前
|
C# 开发者
深入理解C#中的`Task<T>`：异步编程的核心
【1月更文挑战第3天】本文旨在探讨C#中`Task<T>`的使用和理解，作为异步编程模式的核心组件。`Task<T>`允许开发者在不阻塞主线程的情况下执行异步操作，并返回一个指定类型`T`的结果。通过定义返回`Task<T>`的异步方法、使用`async`和`await`关键字、处理异常以及获取任务结果，开发者可以编写出高效且响应迅速的应用程序。此外，本文还介绍了如何配置任务以及实现任务的连续性和组合，为掌握C#中的异步编程提供了全面的指导。
1941623231718325
60 0
jcLee95
|
3月前
|
C# Python
C# 笔记3 - 重载一系列像python那样的print()方法
C# 笔记3 - 重载一系列像python那样的print()方法
jcLee95
27 1
jcLee95
|
3月前
|
存储 C# C++
C# 笔记2 - 数组、集合与与文本文件处理
C# 笔记2 - 数组、集合与与文本文件处理
jcLee95
44 0
凉冰Pro
|
8月前
|
C#
C#异步编程
C#异步编程
凉冰Pro
164 0
LiBihao
|
10月前
|
C#
c#异步编程
c#异步编程原理，await asnyc的使用方法。异步编程是指在程序执行过程中，不需要等待某个操作完成，就可以继续执行后续的代码。
LiBihao
267 0
感谢地心引力
|
10月前
|
存储 网络协议 Java
C# 快速入门笔记
C# 快速入门笔记
感谢地心引力
121 0
C# 快速入门笔记
游客eatp4fx2qnvae
|
C# 开发工具
C#滑动拼图验证码实现笔记
C# 是一个现代的、通用的、面向对象的编程语言，它是由微软(Microsoft)开发的，由 Ecma 和 ISO 核准认可的。突发奇想，动手开发一个C#滑动拼图验证码，下面是我开发过程的记录。
游客eatp4fx2qnvae
162 0
C#滑动拼图验证码实现笔记
writer桑
|
SQL 开发框架 算法
【读书笔记】《Effective C#》50条建议笔记整理
对《Effective C#：改善C#代码的50个有效方法》一书整理的读书笔记。
writer桑
28063 5
【读书笔记】《Effective C#》50条建议笔记整理
码农技术君
|
C# 数据库
C#编程-65：读取数据库DataReader对象复习笔记
C#编程-65：读取数据库DataReader对象复习笔记
码农技术君
66 0
C#编程-65：读取数据库DataReader对象复习笔记

热门文章

最新文章

  • 1
    C#/.NET/.NET Core优秀项目和框架2024年3月简报
  • 2
    APM Server监控
  • 3
    C# 实现 Word 加盖骑缝章效果
  • 4
    C#实现Excel合并单元格数据导入数据集
  • 5
    C# 读取二维数组集合输出到Word预设表格
  • 6
    C#winforms实现windows窗体人脸识别
  • 7
    C# 读取Word表格到DataSet
  • 8
    C#实现基于Word保护性模板文件的修改
  • 9
    C# 将 Word 转化分享为电子期刊
  • 10
    C#拾遗补漏之goto跳转语句
  • 1
    APM Server监控
    46
  • 2
    有人想让我讲讲应用性能管理（APM）工具
    44
  • 3
    Kustomize 生产实战 - 注入监控 APM Agent
    33
  • 4
    APM vs NPM
    61
  • 5
    电子书阅读分享《Elasticsearch全观测技术解析与应用（构建日志、指标、APM统一观测平台）》
    234
  • 6
    阿里云ARMS的新版和老版界面是两套不同的系统
    49
  • 7
    应用性能监控分析
    65
  • 8
    微服务轮子项目（22） -APM监控（SkyWalking）
    219
  • 9
    慢调用链诊断利器-ARMS 代码热点
    206
  • 10
    阿里服务的ASM、MSE和ARMS都有其各自的应用场景
    189

    • 相关课程

    更多
  • 网站性能前端监控课程
  • PHP进阶教程 - 由浅入深掌握面向对象开发 - 第二阶段
  • Cloud Toolkit 开发部署效率提升神器
  • Python语言基础 - 函数、面向对象、异常处理
  • Java面向对象开发
  • 开源Android容器化框架Atlas开发者指南

    • 相关电子书

    更多
  • ARMS打造应用全栈监控
  • 《阿里云云拨测发布》PDF
  • Elasticsearch全观测技术解析与应用（构建日志、指标、APM统一观测平台）

    • 相关实验场景

    更多
  • 通过云拨测对指定服务器进行Ping/DNS监测
  • 通过云拨测对指定网页进行网页性能监测
  • 语言入门-1：环境构建
  • 高性能特性体验：ePQ 的详解与实战
  • 使用Java面向对象编写网络通信程序应用
  • Python网络通信程序典型应用
    • 下一篇
    阿里云oss简介和使用流程
    为什么选择阿里云什么是云计算全球基础设施技术领先稳定可靠安全合规分析师报告
    产品和定价全部产品免费试用产品动态产品定价价格计算器云上成本管理
    解决方案技术解决方案
    文档与社区文档开发者社区天池大赛培训与认证
    权益中心免费试用高校计划企业扶持计划推荐返现计划
    支持与服务基础服务企业增值服务迁云服务官网公告健康看板信任中心
    关注阿里云
    关注阿里云公众号或下载阿里云APP，关注云资讯，随时随地运维管控云服务
    阿里云APP阿里云微信
    联系我们：4008013260
    法律声明Cookies政策廉正举报安全举报联系我们加入我们
    阿里巴巴集团淘宝网天猫全球速卖通阿里巴巴国际交易市场1688阿里妈妈飞猪阿里云计算AliOS万网高德UC友盟优酷钉钉支付宝达摩院淘宝海外阿里云盘饿了么
    © 2009-2024 Aliyun.com 版权所有 增值电信业务经营许可证： 浙B2-20080101 域名注册服务机构许可： 浙D3-20210002 京D3-20220015
    浙公网安备 33010602009975号浙B2-20080101-4