C#多线程之旅(4)——APM初探

原文地址:C#多线程之旅(4)——APM初探

C#多线程之旅目录:

C#多线程之旅(1)——介绍和基本概念

C#多线程之旅(2)——创建和开始线程

C#多线程之旅(3)——线程池

C#多线程之旅(4)——APM初探

C#多线程之旅(5)——同步机制介绍

C#多线程之旅(6)——详解多线程中的锁

更多文章正在更新中,敬请期待......

C#多线程之旅(4)——APM初探

v博客前言

先交代下背景,前面几张内容主要是介绍多线程的基本知识,这一章是因为正好接触到了APM(异步编程模型),发现APM真的很强大,其中有部分知识点涉及到了委托的BeginInvoke/EndInvoke,就由衷地想写下APM相关的知识。

v写在前面

强大的异步处理模型,不得不被它折服!

v正文开始

一、简单的串行执行程序

我们先来看一个简单的程序:

定义了一个int Add(int num),传入循环的次数num,返回循环相加的结果sum。

Step 1.Main方法调用Add方法,循环执行了2次,所以延时了2s,返回结果sum=1,打印 Result:1;

Step 2.Main方法循环执行了3次,延时了3s。

友情提醒:如果觉得不想阅读多彩的Console打印代码,可以选择查看下面折叠的code区域。查看简洁版

去掉颜色打印的code简洁版

让我们看看这个程序的运行结果:

 我们可以从结果中看到:

  1.执行Add方法,是主线程执行Add方法;

  2.执行Main方法,是主线程执行Main方法;

  3.这中限时操作可以称为“计算限制的异步操作”;

  4.Add方法中模拟耗时操作(2s)和Main方法中模拟耗时操作(3s)是串行执行的,那么我们有没有一种方法使这两种操作并行执行了?(3s中之内搞定这两个耗时操作)。答案是可以用APM。

 下面我们用APM方式来节省2s的时间。

二、使用委托来实现APM

2.1 预备知识

我们使用泛型委托来实现APM,那么我们需要点预备知识(对委托很熟练的同学们可以跳过预备知识):

  1.什么是委托?

  2.什么是泛型委托?

  3.为什么使用委托来实现APM?

对于这知识点1、2,可以参考我之前写的博客,在这里就不再说明了,不惧面试:委托

对于第三个知识点,是因为委托定义了两个异步方法BeginInvokeEndInvoke

我们可以先看看泛型委托的定义:

/// <summary>
/// 定义一个泛型委托
/// </summary>
/// <typeparam name="T">输入参数</typeparam>
/// <typeparam name="TResult">返回值</typeparam>
/// <param name="arg">输入参数</param>
/// <returns name="TResult">返回值</returns>
private delegate TResult Func<T, TResult>(T arg);

对于这个定义,C#编译器会将这行代码编译成一个类定义,它的逻辑定义如下:

public sealed class Func<T, TResult> : MulticastDelegate
{
	public Func(Object obj, IntPtr method);
	public TResult Invoke(T arg);
	public IAsyncResult BeginInvoke(T arg, AsyncCallback callback, Object obj);
	public TResult EndInvoke(IAsyncResult result);
}

定义一个委托时,会生成一个BeginInvoke和EndInvoke方法的类。

当定义下面的委托时

public delegate void myDelegate(int value);

通过反编译工具ILSpy查看结果:

BeginInvoke:

  1.第一个参数arg为委托定义相同的参数(可以为两个参数arg,和委托的签名相同),可以传入到委托引用的方法;

  2.倒数第二个参数callback为回调方法,当BeginInvoke方法执行完后,会立即调用回调方法,如果callback=null,则不调用回调方法;

  3.倒数第一个参数object给EndInvoke用的。

  4.返回值为IAsyncResult类型的接口对象(实际上是AsynResult的类型实例)。该接口对象用途

    a.传递参数,它包含了对调用了BeginInvoke的委托的引用,这里是Add方法的int类型的输入参数;

    b.包含了BeginInvoke()的最后一个Object类型的参数

    c.它可以鉴别是哪个方法的哪一次调用,因为通过同一个委托变量可以对同一个方法调用多次。

EndInvoke

  1.第一个参数接收BeginInvoke返回的IAnsyResult;

  2.返回的TResult为委托引用的方法的返回值,这里是Add方法的int类型返回值

2.2 用委托来实现APM的原理

2.3 动手写个实现了APM的Code

通过上面的流程图,相信我们对委托来实现APM有了一定的理解,再来读读code,相信能更快地理解。注释仅作参考,有问题可以回复我哦!

让我们看看结果:

 注意:

  1.必须先将IAsyncResult转换为AsyncResult,才能获取到引用的委托,因为它没有包含在IAsyncResult接口的定义中;

  2.Add方法的调用,AddCallback方法都是线程池线程调用的;

  3.BeginInvoke的object参数可以为任何类型,例子中传递的是string类型的参数"I‘m here!";

  4.主线程执行的for循环和Add方法中线程是同时进行的,交替打印结果;

  5.当异步的Add方法没有执行完毕,调用EndInvoke,则会阻塞当前线程池线程,只有异步方法执行完毕后,才会继续执行的代码;

  6.Add方法执行完后,会自动调用回调方法AddCallback;

  7.在调用EndInvoke可能抛出异常,所以需要加try/catch/finally,捕获EndInvoke的可能抛出的异常。

v写在最后

因为只是刚开始接触APM相关的知识,所以本篇只是写初探的内容,后面的章节会更多地介绍这方面的内容。希望得到园友们的支持!

时间: 2024-11-08 21:23:25

C#多线程之旅(4)——APM初探的相关文章

C#多线程之旅(1)

阅读目录 一.多线程介绍 二.Join 和Sleep 三.线程怎样工作 四.线程和进程 五.线程的使用和误用 原文地址:C#多线程之旅(1)--介绍和基本概念 C#多线程之旅目录: C#多线程之旅(1)--介绍和基本概念 C#多线程之旅(2)--创建和开始线程 C#多线程之旅(3)--线程池 C#多线程之旅(4)--APM初探 C#多线程之旅(5)--同步机制介绍 C#多线程之旅(6)--详解多线程中的锁 更多文章正在更新中,敬请期待...... C#多线程之旅(1)--介绍和基本概念 回到顶部

C#多线程之旅(4)

阅读目录 一.简单的串行执行程序 二.使用委托来实现APM 源码地址:https://github.com/Jackson0714/Threads 原文地址:C#多线程之旅(4)--APM初探 C#多线程之旅目录: C#多线程之旅(1)--介绍和基本概念 C#多线程之旅(2)--创建和开始线程 C#多线程之旅(3)--线程池 C#多线程之旅(4)--APM初探 C#多线程之旅(5)--同步机制介绍 C#多线程之旅(6)--详解多线程中的锁 更多文章正在更新中,敬请期待...... C#多线程之旅

C#多线程之旅(3)

阅读目录 代码下载 一.介绍 二.通过TPL进入线程池 三.不用TPL进入到线程池 v博客前言 先交代下背景,写<C#多线程之旅>这个系列文章主要是因为以下几个原因:1.多线程在C/S和B/S架构中用得是非常多的;2.而且多线程的使用是非常复杂的,如果没有用好,容易造成很多问题. v写在前面 多线程,有利也有弊,使用需谨慎. v正文开始 原文地址:C#多线程之旅(3)--线程池 C#多线程之旅(1)--介绍和基本概念 C#多线程之旅(2)--创建和开始线程 C#多线程之旅(3)--线程池 C#

C#多线程之旅(1)——介绍和基本概念

原文目录C#多线程之旅(1)——介绍和基本概念 C#多线程之旅目录: C#多线程之旅(1)——介绍和基本概念 C#多线程之旅(2)——创建和开始线程 C#多线程之旅(3)——线程池 C#多线程之旅(4)——同步本质 ...... C#多线程之旅(1)——介绍和基本概念 一.多线程介绍 C#通过多线程支持并行执行的代码.一个线程是一个独立执行的路径,可以同时与其他线程一起运行.一个C#客户端程序(Console,WPF,Winows Forms)开始于一个单独的线程,该线程由CLR和操作系统自动地

C#多线程之旅(3)——线程池

v博客前言 先交代下背景,写<C#多线程之旅>这个系列文章主要是因为以下几个原因:1.多线程在C/S和B/S架构中用得是非常多的;2.而且多线程的使用是非常复杂的,如果没有用好,容易造成很多问题. v写在前面 多线程,有利也有弊,使用需谨慎. v正文开始 原文地址:C#多线程之旅(3)——线程池 C#多线程之旅目录: C#多线程之旅(1)——介绍和基本概念 C#多线程之旅(2)——创建和开始线程 C#多线程之旅(3)——线程池 C#多线程之旅(4)——同步本质 ...... 一.介绍 无论你什

NHibernate之旅(18):初探代码生成工具使用

本节内容 引入 代码生成工具 结语 引入 我们花了大量的篇幅介绍了相关NHibernate的知识.一直都是带着大家手动编写代码,首先创建数据库架构.然后编写持久化类和映射文件,最后编写数据操作方法.測试方法. 这是典型的数据库驱动开发(DbDD,Database-Driven Developent)技术.可是自己不是这样做的,我先编写持久化类和映射文件,然后偷偷的使用SchemaExport工具把数据库生成了.按上面的步骤写文章的,关于SchemaExport工具就是下一篇的事情了,这篇说说利用

NHibernate之旅(7):初探NHibernate中的并发控制

本节内容 什么是并发控制? 悲观并发控制(Pessimistic Concurrency) 乐观并发控制(Optimistic Concurrency) NHibernate支持乐观并发控制 实例分析 结语 什么是并发控制? 当许多人试图同时修改数据库中的数据时,必须实现一个控制系统,使一个人所做的修改不会对他人所做的修改产生负面影响.这称为并发控制. 简单的理解就是2个或多个用者同时编辑相同的数据.这里的用者可能是:实际用户.不同服务.不同的代码段(使用多线程),及其在断开式和连接式情况下可能

[转]NHibernate之旅(7):初探NHibernate中的并发控制

本节内容 什么是并发控制? 悲观并发控制(Pessimistic Concurrency) 乐观并发控制(Optimistic Concurrency) NHibernate支持乐观并发控制 实例分析 结语 什么是并发控制? 当许多人试图同时修改数据库中的数据时,必须实现一个控制系统,使一个人所做的修改不会对他人所做的修改产生负面影响.这称为并发控制. 简单的理解就是2个或多个用者同时编辑相同的数据.这里的用者可能是:实际用户.不同服务.不同的代码段(使用多线程),及其在断开式和连接式情况下可能

Scratch克隆技术、多线程编程及通讯技术初探

一.引言 Scratch,作为世界流行的青少年编程语言,其对青少年智力的开发及计算思维的培养根本毋庸置疑.既然定位在青少年,那就不能复杂,但是,又要遵循"低门槛,高上限"两个基本特征.让青少年尽快入门的同时,又可以让部分能够深入钻研的同学深刻体会到编程的创造性.复杂性及内在乐趣.而后者,在全国青少年编程竞赛与等级考试中肯定要体现出来--自然也是体现参加者作品创意与难度的所在. Scratch开发者恰当地把握了上述要求与特征:最基础最重要的计算机编程语言特征必须具备,同时又尽可能巧妙地&