热门标签 | HotTags
当前位置:  开发笔记 > 运维 > 正文

在.NETCore中使用异步编程的方法步骤

这篇文章主要介绍了在.NETCore中使用异步编程的方法步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

近期对于异步和多线程编程有些启发,所以我决定把自己的理解写下来。

思考:为什么要使用异步编程?

我们先看看同步方法和异步方法之前在程序中执行的逻辑:

1. 同步方法

static void Main(string[] args)
{
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:开始");
  // 调用同步方法
  SyncTestMethod();
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:结束");
  Console.ReadKey();
}

/// 
/// 同步方法
/// 
static void SyncTestMethod()
{
  for (int i = 0; i <10; i++)
  {
    var str = $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:SyncTestMethod{i}";
    Console.WriteLine(str);
    Thread.Sleep(10);
  }
}

控制台打印:

2019-03-26 14:44:05 445:开始
2019-03-26 14:44:05 445:SyncTestMethod0
2019-03-26 14:44:05 445:SyncTestMethod1
2019-03-26 14:44:05 445:SyncTestMethod2
2019-03-26 14:44:05 445:SyncTestMethod3
2019-03-26 14:44:05 445:SyncTestMethod4
2019-03-26 14:44:05 445:SyncTestMethod5
2019-03-26 14:44:05 445:SyncTestMethod6
2019-03-26 14:44:05 445:SyncTestMethod7
2019-03-26 14:44:05 445:SyncTestMethod8
2019-03-26 14:44:05 445:SyncTestMethod9
2019-03-26 14:44:05 445:结束

主线程在调用同步方法时,会直接在主线程中执行同步方法,这个时候若SyncTestMethod方法后面还有其它方法,都需要等待SyncTestMethod执行完成。

 

2. 异步方法

static void Main(string[] args)
{
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:开始");
  // 调用异步步方法
  AsyncTestMethod();
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:结束");
  Console.ReadKey();
}


/// 
/// 异步方法
/// 
/// 
static async Task AsyncTestMethod() {
  await Task.Run(() => {
    for (int i = 0; i <10; i++)
    {
      Console.WriteLine($"AsyncTestMethod");
      Thread.Sleep(10);
    }
  });
}

控制台打印:

2019-03-26 14:52:37 5237:开始
2019-03-26 14:52:37 5237:结束
2019-03-26 14:52:37 5237:AsyncTestMethod
2019-03-26 14:52:37 5237:AsyncTestMethod
2019-03-26 14:52:37 5237:AsyncTestMethod
2019-03-26 14:52:37 5237:AsyncTestMethod
2019-03-26 14:52:37 5237:AsyncTestMethod
2019-03-26 14:52:37 5237:AsyncTestMethod
2019-03-26 14:52:37 5237:AsyncTestMethod
2019-03-26 14:52:37 5237:AsyncTestMethod
2019-03-26 14:52:37 5237:AsyncTestMethod
2019-03-26 14:52:37 5237:AsyncTestMethod

主线程在调用异步方法时,将会新建一个子线程去执行异步方法,调用过AsyncTestMethod方法之后,将会直接执行AsyncTestMethod后面的方法,这个时候主线程不会等待异步方法执行完成;因为这个时候主线程无法知晓异步方法会在什么时候执行完成,所以此时也无法在主线程中直接获取异步方法的返回,如果需要在异步方法执行完成之后再在主线程中执行其它方法,则需要使用Wait()来等待异步子线程执行完成。

3. 等待(awiat)异步方法

static void Main(string[] args)
{
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:开始");
  // 调用异步步方法
  AsyncTestMethod();
  // 等待异步方法执行完成
  m1.Wait();
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:结束");
  Console.ReadKey();
}


/// 
/// 异步方法
/// 
/// 
static async Task AsyncTestMethod() {
  await Task.Run(() => {
    for (int i = 0; i <10; i++)
    {
      Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:AsyncTestMethod");
      Thread.Sleep(10);
    }
  });
}

控制台打印:

2019-03-26 14:55:51 5551:开始
2019-03-26 14:55:51 5551:AsyncTestMethod
2019-03-26 14:55:51 5551:AsyncTestMethod
2019-03-26 14:55:51 5551:AsyncTestMethod
2019-03-26 14:55:51 5551:AsyncTestMethod
2019-03-26 14:55:51 5551:AsyncTestMethod
2019-03-26 14:55:51 5551:AsyncTestMethod
2019-03-26 14:55:51 5551:AsyncTestMethod
2019-03-26 14:55:51 5551:AsyncTestMethod
2019-03-26 14:55:51 5551:AsyncTestMethod
2019-03-26 14:55:51 5551:AsyncTestMethod
2019-03-26 14:55:51 5551:结束

主线程在调用异步方法时,将会新建一个子线程去执行异步方法,并且在调用AsyncTestMethod方法之后执行了对AsyncTestMethod方法的等待Wait(),这个时候主线程会等待异步方法执行完成,不会执行后续的方法,在AsyncTestMethod执行完成之后,等待结束,此时可以拿到异步方法AsyncTestMethod的返回值,然后再继续执行主线程中的方法。

4. 同步线程和异步线程关联执行

如有以下方法:

static int Method1()
{
  Thread.Sleep(200);
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:我计算了一个值耗费200ms");
  return 1;
}
static int Method200ms()
{
  Thread.Sleep(200);
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:我做了一件耗费200ms的事情");
  return 200;
}
static int Method500ms(int index)
{
  Thread.Sleep(500);
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:我做了一件耗费500ms的事情");
  return ++index;
}
static int Method1000ms()
{
  Thread.Sleep(1000);
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:我做了一件耗费1000ms的事情");
  return 1000;
}

Method500ms()需要Method1()的返回值作为参数,如果所有的方法同步执行在最后计算a、b、c、d的和:

static void Main(string[] args)
{
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:开始");
  var a = Method1();
  var b = Method200ms();
  var c = Method500ms(a);
  var d = Method1000ms();
  var result = a+b+c+d;
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:最后得到的结果{result}");
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:结束");
  Console.ReadKey();
}

控制台打印:

2019-03-26 15:10:06 106:开始
2019-03-26 15:10:06 106:我计算了一个值耗费200ms
2019-03-26 15:10:06 106:我做了一件耗费200ms的事情
2019-03-26 15:10:07 107:我做了一件耗费500ms的事情
2019-03-26 15:10:08 108:我做了一件耗费1000ms的事情
2019-03-26 15:10:08 108:最后得到的结果1203
2019-03-26 15:10:08 108:结束

同步执行的时候,需要逐一等待所有的方法执行完成,花费的时间显然是所有的方法耗费的时间之和。

对于以上四个方法,如果使用异步的方式来执行,将会很大程度的节省程序的运行时间,修改方法如下:

static async Task AsyncMethod1()
{
  await Task.Run(()=> {
    Thread.Sleep(200);
    Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:我计算了一个值耗费200ms");
  });
  return 1;
}
static async Task AsyncMethod200ms()
{
  await Task.Run(() => {
    Thread.Sleep(200);
    Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:我做了一件耗费200ms的事情");
  });
  return 200;
}
static async Task AsyncMethod500ms(int index)
{
  await Task.Run(() => {
    Thread.Sleep(500);
    Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:我做了一件耗费500ms的事情");
  });
  return ++index;
}
static async Task AsyncMethod1000ms()
{
  await Task.Run(() => {
    Thread.Sleep(1000);
    Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:我做了一件耗费1000ms的事情");
  });
  return 1000;
}

使用异步的方式来调用方法:

static void Main(string[] args)
{
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:开始");
  var m1 = AsyncMethod1();
  var m2 = AsyncMethod200ms();
  var m4 = AsyncMethod1000ms();
  m1.Wait();
  var m3 = AsyncMethod500ms(m1.Result);
  m2.Wait();
  m3.Wait();
  m4.Wait();
  var result = m1.Result + m2.Result + m3.Result + m4.Result;
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:最后得到的结果{result}");
  Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ms")}:结束");
  Console.ReadKey();
}

控制台打印:

2019-03-26 14:11:54 1154:开始
2019-03-26 14:11:54 1154:我计算了一个值耗费200ms
2019-03-26 14:11:54 1154:我做了一件耗费200ms的事情
2019-03-26 14:11:55 1155:我做了一件耗费500ms的事情
2019-03-26 14:11:55 1155:我做了一件耗费1000ms的事情
2019-03-26 14:11:55 1155:最后得到的结果1203
2019-03-26 14:11:55 1155:结束

因为 AsyncMethod500ms() 依赖于 AsyncMethod1() 的返回结果作为参数,所以我们可以先直接以异步的方式运行 AsyncMethod1()AsyncMethod200ms()AsyncMethod1000ms() 三个方法,这个时候三个方法都会建立异步的子线程进行执行,但是后面的 AsyncMethod500ms() 想要执行,必须的有 AsyncMethod1() 的返回值,所以这个时候对 AsyncMethod1() 进行等待, 200ms 后, AsyncMethod1() 执行完成, m1.Wait() 等待结束,继续执行 AsyncMethod500ms() ,并传入了 AsyncMethod1() 的返回值 m1.Result ,最后因为需要对四个方法的返回值进行累加,所以在这之前必须保证其它三个方法也执行完成,所以需要分别对 AsyncMethod500ms()AsyncMethod200ms()AsyncMethod1000ms() 进行等待(Wait),因为此刻所有的方法都是异步执行的,所以程序的执行时间将≈执行时间最长的那个方法的执行时间( AsyncMethod1000ms() 执行 1000ms ,执行时间最长,程序的执行时间≈ 1000ms )。

看完上面的内容,可以确定的是,在某些情况下,异步编程能够很大的提高我们程序运行的效率,但是大家都在推崇的多使用异步编程不仅仅是因为软件上面的原因,在硬件上也有着很大的原因。

前段时间我们将原来跑在一台办公电脑的程序发布到一台双路E5的DELL的刀片机上面去,结果发现在DELL刀片机上面运行的性能竟然比之前的办公电脑还差,开始我们怀疑是DELL刀片机使用的是虚拟机的问题,可能在某些地方没有设置好,后来经过一系列的服务器性能测试,无论是CPU处理速度、磁盘IO还是网络带宽,DELL刀片机都远超我们之前的那台办公电脑,但是我们运行的程序中的某个接口在效率上就是不如之前的办公电脑!!!

&#63;&#63;&#63;(直到后来的某一天,随着我对.NET Core异步编程的理解的加深,终于明白是什么原因。)

我们先来看一下我们日常开发使用的Intel CPU和服务器使用的CPU对比

开发电脑CPU: 英特尔® 酷睿&#8482; i5+8500 处理器

  • 处理器基本频率:3GHz
  • 最大睿频频率:4.1GHz
  • 内核数:六核心
  • 线程数:六线程

服务器CPU: 英特尔® 至强® D-2177NT 处理器

  • 处理器基本频率:1.90 GHz
  • 最大睿频频率:3.00 GHz
  • 内核数:14
  • 线程数:28

从上面的对比我们可以发现两者之间的差异很明显, i5 处理器的基本频率和最大睿频都高于服务器使用的 至强 处理器,但是在内核数量和线程数量上面却远远不如 至强 ,如果我们的程序全部使用的同步编程的话,以WebApi为例,每一次请求中调用的方法都只是在CPU的某一个内核/线程中进行的,换句话说,CPU单核频率的高低直接影响着同步方法的执行效率,而我们之前的程序几乎都是使用了同步方法,在办公电脑上的 i5 处理器和服务器使用的 至强 处理器的单核频率的差异显然就是之前性能问题的直接原因。

并且鉴于服务器CPU的特性(单核频率低,内核/线程数多),在程序中多使用异步/多线程的方式对于程序的性能而言是无容置疑的。

注意:

虽然异步编程很多时候能提升程序的效率,但不并意味着需要为了使用异步而将所有的方法改为异步执行,如果同步执行的开销甚至比创建一个异步线程开销还低的时候,就完全没有必要再此处使用异步的方式。至于这其中的权衡利弊,或许需要一定的经验才能拿捏的住。

以上就是我目前对.NET Core中使用异步/多线程编程方式的理解, 希望对大家的学习有所帮助,也希望大家多多支持。


推荐阅读
  • 本文介绍了在rhel5.5操作系统下搭建网关+LAMP+postfix+dhcp的步骤和配置方法。通过配置dhcp自动分配ip、实现外网访问公司网站、内网收发邮件、内网上网以及SNAT转换等功能。详细介绍了安装dhcp和配置相关文件的步骤,并提供了相关的命令和配置示例。 ... [详细]
  • 搭建Windows Server 2012 R2 IIS8.5+PHP(FastCGI)+MySQL环境的详细步骤
    本文详细介绍了搭建Windows Server 2012 R2 IIS8.5+PHP(FastCGI)+MySQL环境的步骤,包括环境说明、相关软件下载的地址以及所需的插件下载地址。 ... [详细]
  • 本文介绍了如何找到并终止在8080端口上运行的进程的方法,通过使用终端命令lsof -i :8080可以获取在该端口上运行的所有进程的输出,并使用kill命令终止指定进程的运行。 ... [详细]
  • 禁止程序接收鼠标事件的工具_VNC Viewer for Mac(远程桌面工具)免费版
    VNCViewerforMac是一款运行在Mac平台上的远程桌面工具,vncviewermac版可以帮助您使用Mac的键盘和鼠标来控制远程计算机,操作简 ... [详细]
  • 本文详细介绍了云服务器API接口的概念和作用,以及如何使用API接口管理云上资源和开发应用程序。通过创建实例API、调整实例配置API、关闭实例API和退还实例API等功能,可以实现云服务器的创建、配置修改和销毁等操作。对于想要学习云服务器API接口的人来说,本文提供了详细的入门指南和使用方法。如果想进一步了解相关知识或阅读更多相关文章,请关注编程笔记行业资讯频道。 ... [详细]
  • 阿,里,云,物,联网,net,core,客户端,czgl,aliiotclient, ... [详细]
  • [译]技术公司十年经验的职场生涯回顾
    本文是一位在技术公司工作十年的职场人士对自己职业生涯的总结回顾。她的职业规划与众不同,令人深思又有趣。其中涉及到的内容有机器学习、创新创业以及引用了女性主义者在TED演讲中的部分讲义。文章表达了对职业生涯的愿望和希望,认为人类有能力不断改善自己。 ... [详细]
  • 如何基于ggplot2构建相关系数矩阵热图以及一个友情故事
    本文介绍了如何在rstudio中安装ggplot2,并使用ggplot2构建相关系数矩阵热图。同时,通过一个友情故事,讲述了真爱难觅的故事背后的数据量化和皮尔逊相关系数的概念。故事中的小伙伴们在本科时参加各种考试,其中有些沉迷网络游戏,有些热爱体育,通过他们的故事,展示了不同兴趣和特长对学习和成绩的影响。 ... [详细]
  • 如何用UE4制作2D游戏文档——计算篇
    篇首语:本文由编程笔记#小编为大家整理,主要介绍了如何用UE4制作2D游戏文档——计算篇相关的知识,希望对你有一定的参考价值。 ... [详细]
  • 本文介绍了使用PHP实现断点续传乱序合并文件的方法和源码。由于网络原因,文件需要分割成多个部分发送,因此无法按顺序接收。文章中提供了merge2.php的源码,通过使用shuffle函数打乱文件读取顺序,实现了乱序合并文件的功能。同时,还介绍了filesize、glob、unlink、fopen等相关函数的使用。阅读本文可以了解如何使用PHP实现断点续传乱序合并文件的具体步骤。 ... [详细]
  • 本文介绍了Hyperledger Fabric外部链码构建与运行的相关知识,包括在Hyperledger Fabric 2.0版本之前链码构建和运行的困难性,外部构建模式的实现原理以及外部构建和运行API的使用方法。通过本文的介绍,读者可以了解到如何利用外部构建和运行的方式来实现链码的构建和运行,并且不再受限于特定的语言和部署环境。 ... [详细]
  • 关于我们EMQ是一家全球领先的开源物联网基础设施软件供应商,服务新产业周期的IoT&5G、边缘计算与云计算市场,交付全球领先的开源物联网消息服务器和流处理数据 ... [详细]
  • 图解redis的持久化存储机制RDB和AOF的原理和优缺点
    本文通过图解的方式介绍了redis的持久化存储机制RDB和AOF的原理和优缺点。RDB是将redis内存中的数据保存为快照文件,恢复速度较快但不支持拉链式快照。AOF是将操作日志保存到磁盘,实时存储数据但恢复速度较慢。文章详细分析了两种机制的优缺点,帮助读者更好地理解redis的持久化存储策略。 ... [详细]
  • http:my.oschina.netleejun2005blog136820刚看到群里又有同学在说HTTP协议下的Get请求参数长度是有大小限制的,最大不能超过XX ... [详细]
  • 本文介绍了高校天文共享平台的开发过程中的思考和规划。该平台旨在为高校学生提供天象预报、科普知识、观测活动、图片分享等功能。文章分析了项目的技术栈选择、网站前端布局、业务流程、数据库结构等方面,并总结了项目存在的问题,如前后端未分离、代码混乱等。作者表示希望通过记录和规划,能够理清思路,进一步完善该平台。 ... [详细]
author-avatar
263企业邮箱温州授权合作伙伴
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有