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

阅读目录

  • 一、简单的串行执行程序
  •  二、使用委托来实现APM

源码地址:https://github.com/Jackson0714/Threads

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

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

1

2

3

4

5

6

7

8

/// <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#编译器会将这行代码编译成一个类定义,它的逻辑定义如下:

1

2

3

4

5

6

7

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方法的类。

当定义下面的委托时

1

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相关的知识,所以本篇只是写初探的内容,后面的章节会更多地介绍这方面的内容。希望得到园友们的支持!


作  者: Jackson0714 
出  处:http://www.cnblogs.com/jackson0714/ 
关于作者:专注于微软平台的项目开发。如有问题或建议,请多多赐教! 
版权声明:本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文链接。 
特此声明:所有评论和私信都会在第一时间回复。也欢迎园子的大大们指正错误,共同进步。或者直接私信我 
声援博主:如果您觉得文章对您有帮助,可以点击文章右下角【推荐】一下。您的鼓励是作者坚持原创和持续写作的最大动力! 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/438225.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

阿里巴巴消息中间件: Spring Cloud Stream

Spring Cloud Stream是一个框架&#xff0c;用于构建与共享消息传递系统连接的高度可扩展的事件驱动微服务。 该框架提供了一个灵活的编程模型&#xff0c;该模型基于已经建立和熟悉的Spring习语和最佳实践&#xff0c;包括对持久性发布/订阅语义&#xff0c;消费者组和有状态…

C#多线程编程系列(五)- C# ConcurrentBag的实现原理

目录 一、前言二、ConcurrentBag类三、 ConcurrentBag线程安全实现原理 1. ConcurrentBag的私有字段2. 用于数据存储的ThreadLocalList类3. ConcurrentBag实现新增元素4. ConcurrentBag 如何实现迭代器模式四、总结笔者水平有限&#xff0c;如果错误欢迎各位批评指正&#xff…

Spring Boot 常用注解

SpringBootApplication 查看源码可发现&#xff0c;SpringBootApplication是一个复合注解&#xff0c;包含了SpringBootConfiguration&#xff0c;EnableAutoConfiguration&#xff0c;ComponentScan这三个注解 SpringBootConfiguration 注解&#xff0c;继承Configuration注…

C#多线程编程系列(五)- 浅析C# Dictionary实现原理

目录 一、前言二、理论知识 1、Hash算法2、Hash桶算法3、解决冲突算法三、Dictionary实现 1. Entry结构体2. 其它关键私有变量3. Dictionary - Add操作4. Dictionary - Find操作5. Dictionary - Remove操作6. Dictionary - Resize操作(扩容)7. Dictionary - 再谈Add操作8. Col…

Java中的list、set、map区别

List 有序,可重复 ArrayList 优点: 底层数据结构是数组&#xff0c;查询快&#xff0c;增删慢。 缺点: 线程不安全&#xff0c;效率高 Vector 优点: 底层数据结构是数组&#xff0c;查询快&#xff0c;增删慢。 缺点: 线程安全&#xff0c;效率低 LinkedList 优点: 底层数据结…

ASP.NET MVC 入门5、View与ViewData

本系列文章基于ASP.NET MVC Preview5. view在MVC模式中与用户进行最直接的接触&#xff0c;它负责数据的呈现。这里要注意一点就是&#xff0c;view只是负责数据的呈现&#xff0c;所以我们应该要尽量让view中不涉及业务逻辑的处理。 我们来添加一个Blog首页的view。在安装了…

ASP.NET MVC 入门6、TempData

本系列文章基于ASP.NET MVC Preview5. ASP.NET MVC的TempData用于传输一些临时的数据&#xff0c;例如在各个控制器Action间传递临时的数据或者给View传递一些临时的数据&#xff0c;相信大家都看过“在ASP.NET页面间传值的方法有哪几种”这个面试题&#xff0c;在ASP.NET MVC…

ASP.NET MVC 入门11、使用AJAX

本系列文章基于ASP.NET MVC beta.本示例Blog系统同步更新的演示站点&#xff1a;http://4mvcblog.qsh.in/ 在ASP.NET MVC beta发布之前&#xff0c;M$就宣布支持开源的JS框架jQuery&#xff0c;然后ASP.NET MVC beta发布后&#xff0c;你建立一个ASP.NET MVC beta的项目后&…

.NET三种异步模式(APM、EAP、TAP)

APM模式&#xff1a; .net 1.0时期就提出的一种异步模式&#xff0c;并且基于IAsyncResult接口实现BeginXXX和EndXXX类似的方法。 .net中有很多类实现了该模式(比如HttpWebRequest)&#xff0c;同时我们也可以自定义类来实现APM模式(继承IAsyncResult接口并且实现BeginXXX和E…

Nacos 使用

环境准备 64 bit OS&#xff0c;支持 Linux/Unix/Mac/Windows&#xff0c;推荐选用 Linux/Unix/Mac。64 bit JDK 1.8&#xff1b;下载 & 配置。Maven 3.2.x&#xff1b;下载 & 配置。 下载 Nacos 并启动 Nacos server。 启动配置管理 启动了 Nacos server 后&#x…

四种并发编程模型简介

概述 并发往往和并行一起被提及&#xff0c;但是我们应该明确的是“并发”不等同于“并行” • 并发 &#xff1a;同一时间 对待 多件事情 &#xff08;逻辑层面&#xff09; • 并行 &#xff1a;同一时间 做(执行) 多件事情 (物理层面) 并发可以构造出一种问题解…

easyexcel操作Excel导入导出

需要添加maven依赖 <dependency><groupId>com.alibaba</groupId><artifactId>easyexcel</artifactId><version>3.0.5</version></dependency> 读Excel package com.alibaba.easyexcel.test.demo.read;import java.io.File; …

从编译到执行,C++如何开发SIMD友好的代码?

一&#xff1a;名词解释 Flynn分类法 Flynn于1972年提出了计算平台的Flynn分类法,主要根据指令流和数据流来分类。按照Flynn分类法&#xff0c;计算平台共分为四种类型。 1.单指令流单数据流机器(SISD) 2.单指令流多数据流机器(SIMD) 3.多指令流单数据流机器(MISD) 4.多指令流…

Nacos介绍

Nacos 英文全称为 Dynamic Naming and Configuration Service&#xff0c;是一个由阿里巴巴团队使用 Java 语言开发的开源项目。 参考:home (nacos.io) Nacos 是一个更易于帮助构建云原生应用的动态服务发现、配置和服务管理平台&#xff0c;可以将 Nacos 理解成服务注册中心…

在部署 C#项目时转换 App.config 配置文件

问题 部署项目时&#xff0c;常常需要根据不同的环境使用不同的配置文件。例如&#xff0c;在部署网站时可能希望禁用调试选项&#xff0c;并更改连接字符串以使其指向不同的数据库。在创建 Web 项目时&#xff0c;Visual Studio 自动生成了 Web.config、Web.Debug.config、We…

@Transactional

事务场景中&#xff0c;抛出异常被catch后&#xff0c;如果需要回滚&#xff0c;一定要手动回滚事务。 Spring事务框架默认只在抛出RuntimeException和unchecked exceptions时才将事务回滚&#xff08;Errors默认 - 事务回滚&#xff09;&#xff0c;但是抛出的Checked except…

设计模式之Factory

设计模式之Factory 2016-08-04 11:57 设计模式总共有23种模式这种都仅仅是为了一个目的&#xff1a;解耦解耦解耦...&#xff08;高内聚低耦合满足开闭原则&#xff09; 介绍: Factory Pattern有3种当然是全部是creational pattern。 1.Simple Factory Pattern 2.Factory…

centos 7 中没有iptables 和service iptables save 指令使用失败问题解决方案

1.任意运行一条iptables防火墙规则配置命令&#xff1a; iptables -P OUTPUT ACCEPT 2.对iptables服务进行保存&#xff1a; service iptables save 如果上述命令执行失败报出&#xff1a;The service command supports only basic LSB actions (start, stop, restart,…

linux防火墙查看及白名单配置

1、基本操作 1、开启防火墙 systemctl start firewalld 2、关闭防火墙 systemctl stop firewalld ​3、重启防火墙 firewall-cmd --reload ​ #Linux防火墙--iptables--白名单配置 端口开通给指定IP iptables -I INPUT -s 10.1.1.1 -p tcp -m tcp --dport 80 -j ACCEPT #查看…

C#多线程之旅(七)——终止线程

阅读目录 一、什么时候用Thread.Abort();二、Thread.Abort的用法三、无法终止线程的情形四、Catch块中抛出异常五、Finally块中抛出异常六、Abort调用的时间先交代下背景&#xff0c;写《C#多线程之旅》这个系列文章主要是因为以下几个原因&#xff1a;1.多线程在C/S和B/S架构中…