共享内存 Actor并发模型到底哪个快?

HI,前几天被.NET圈纪检委@懒得勤快问到共享内存Actor并发模型哪个速度更快。

前文传送门:《三分钟掌握共享内存 & Actor并发模型

说实在,我内心10w头羊驼跑过.....

先说结论

1.首先两者对于并发的风格模型不一样。

共享内存利用多核CPU的优势,使用强一致的锁机制控制并发, 各种锁交织,稍不注意可能出现死锁,更适合熟手。

Actor模型易于控制和管理,以消息触发、流水线挨个处理,天然分布式,思路清晰。

2.真要说性能,求100_000 以内的素数的个数]场景 & 电脑8c 16g的配置

•2.1 理论上如果以默认的Actor并发模型来做这个事情,共享内存模型是优于Actor模型的;•2.2 上文中我对于Actor做了多线程优化,Actor模型性能慢慢追上来了。
下面请听我唠嗑。

默认Actor模型

计算[100_000内素数的个数], 分为两步:
(1) 迭代判断当前数字是不是素数
(2) 如果是素数,执行sum++

完成以上两步,共享内存模型均能充分利用CPU多核心。

Actor模型:与TPL中的原语不同,TPL Datflow中的所有块默认是单线程的,这就意味着完成以上两步的TransfromBlockActionBlock都是以一个线程挨个处理消息数据 (这也是Dataflow的设计初衷,形成清晰单纯的流水线)。

猜测此时:共享内存相比默认的Actor模型更具优势。

使用NUnit做单元测试,数据量从小到大: 10_000,50_000,100_000,200_000,300_000,500_000

using NUnit.Framework;
using System;
using System.Threading.Tasks;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks.Dataflow;namespace TestProject2
{public class Tests{[TestCase(10_000)][TestCase(50_000)][TestCase(100_000)][TestCase(200_000)][TestCase(300_000)][TestCase(500_000)]public void ShareMemory(int num){var sum = 0;Parallel.For(1, num + 1, (x, state) =>{var f = true;if (x == 1)f = false;for (int i = 2; i <= x / 2; i++){if (x % i == 0)  // 被[2,x/2]任一数字整除,就不是质数f = false;}if (f == true){Interlocked.Increment(ref sum);// 共享了sum对象,“++”就是调用sum对象的成员方法}});Console.WriteLine($"1-{num}内质数的个数是{sum}");}[TestCase(10_000)][TestCase(50_000)][TestCase(100_000)][TestCase(200_000)][TestCase(300_000)][TestCase(500_000)]public async Task Actor(int num){var linkOptions = new DataflowLinkOptions { PropagateCompletion = true };var bufferBlock = new BufferBlock<int>();var transfromBlock = new TransformBlock<int, bool>(x =>{var f = true;if (x == 1)f = false;for (int i = 2; i <= x / 2; i++){if (x % i == 0)  // 被[2,x/2]任一数字整除,就不是质数f = false;}return f;}, new ExecutionDataflowBlockOptions { EnsureOrdered = false });var sum = 0;var actionBlock = new ActionBlock<bool>(x =>{if (x == true)sum++;}, new ExecutionDataflowBlockOptions {  EnsureOrdered = false });transfromBlock.LinkTo(actionBlock, linkOptions);// 准备从pipeline头部开始投递try{var list = new List<int> { };for (int i = 1; i <= num; i++){var b = await transfromBlock.SendAsync(i);if (b == false){list.Add(i);}}if (list.Count > 0){Console.WriteLine($"md,num post failure,num:{list.Count},post again");// 再投一次foreach (var item in list){transfromBlock.Post(item);}}transfromBlock.Complete();  // 通知头部,不再投递了; 会将信息传递到下游。actionBlock.Completion.Wait();  // 等待尾部执行完Console.WriteLine($"1-{num} Prime number include {sum}");}catch (Exception ex){Console.WriteLine($"1-{num} cause exception.",ex);}   }}
}

测试结果如下:

测试结果印证我说的结论2.1

优化后的Actor模型

那后面我对Actor做了什么优化呢?  能产生下图的2.2结论。

请重新回看《三分钟掌握共享内存 & Actor并发模型》 TransfromBlock 块的细节:

var transfromBlock = new TransformBlock<int, bool>(x =>{var f = true;if (x == 1)f = false;for (int i = 2; i <= x / 2; i++){if (x % i == 0)  // 被[2,x/2]任一数字整除,就不是质数f = false;}return f;}, new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism=50, EnsureOrdered = false }); // 这里开启多线程并发

上面说到默认的Actor是以单线程处理输入的消息,此次我们对这个TransfromBlock 块设置了MaxDegreeOfParallelism 参数,

这个参数能在Actor中开启多线程并发执行,但是这里面就不能有共享变量(否则你又得加锁),恰好我们完成 (1) 迭代判断当前数字是不是素数这一步并不依赖共享对象,所以这(1)步开启多线程以后性能与共享内存模型基本没差别。

那为什么总体性能慢慢超过共享内存?

这是因为执行第二步(2) 如果是素数,执行sum++, 共享内存要加/解锁,线程切换; 而Actor单线程挨个处理, 总体上Actor就略胜共享内存模型了。

这里再次强调,Actor模型执行第二步(2) 如果是素数,执行sum++,不可开启MaxDegreeOfParallelism,因为依赖了共享变量sum

结束语

That's All, 感谢.NET圈纪检委@懒得勤快促使我重温了单元测试的写法 & 深度分析Actor模型风格。

请大家仔细对比结论和上图,脱离场景和硬件环境谈性能就是耍流氓,理解不同并发模型的风格和能力是关键, 针对场景和未来的拓展性、可维护性、可操作性做技术选型 。

本文内容和制图均为原创,文章永久更新地址请参阅左下角原文,如对您有所帮助,请一键三连,方便的话置一个星标 ~。。~。

专题相关 一网打尽

  三分钟掌握共享内存 & Actor并发模型

 你管这叫"线程安全"?

 .Net线程同步技术解读

 Redis分布式锁抽丝剥茧

 看过这么多爆文,依旧走不好异步编程这条路?

 TPL Dataflow组件应对高并发,低延迟要求

 如何利用.NETCore向Azure EventHubs准实时批量发送数据?

 难缠的布隆过滤器,这次终于通透了

扫码关注我们

不会让您失望的。

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

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

相关文章

web service

一、Web Service简介 1.1、Web Service基本概念 Web Service也叫XML Web Service WebService是一种可以接收从Internet或者Intranet上的其它系统中传递过来的请求&#xff0c;轻量级的独立的通讯技术。是:通过SOAP在Web上提供的软件服务&#xff0c;使用WSDL文件进行说明&#…

来自爸妈的敷衍问候!| 今日最佳

全世界只有3.14 % 的人关注了青少年数学之旅

SBO中的manager用户已锁定

刚建一个账套。因为好奇就找 一些功能看看。一不小心走到用户设置中&#xff0c;勾选 了“已锁定”&#xff0c;结果账套打不开了。而且就一个用户。没有办法了就在网上找资料&#xff0c;最后找到用户表&#xff0c;从表中相应字段&#xff0c;结果修改过来就OK了。开心。转载…

android蓝牙设计与实现,一个Android客户端的蓝牙支付系统设计与实现

摘要&#xff1a;本文实现了一种利用Android系统上的蓝牙技术,完成用户间资金流动的功能。本功能基于一个电子钱包客户端,本人希望以此来拓展电子钱包支付的途径,给用户提供一种新的便捷、安全的支付渠道。并希望借此功能引起支付行业对蓝牙技术的重新审视。蓝牙技术的诞生,已经…

Android系统如何实现UI的自适应

2019独角兽企业重金招聘Python工程师标准>>> 做Android应用的人都知道&#xff0c;要一个apk适用多个不同的手机屏幕是很容易的&#xff0c;就是在项目的res文件夹下面有多套相关的资源文件。程序运行的 时候&#xff0c;Android系统会根据当前设备的信息去加载不同…

javac手动编译servlet

javac -classpath D:\tomcat\common\lib\servlet-api.jar;D:\tomcat\webapps\beer-v1\WEB-INF\classes ../model/BeerExpert.java javac -classpath D:\tomcat\common\lib\servlet-api.jar;D:\tomcat\webapps\beer-v1\WEB-INF\classes BeerSelect.java pause 转载于:https://…

自定义EventSource(二)PollingCounter

在自定义EventSource时&#xff0c;可以使用四种EventCounter&#xff1a;EventCounter&#xff1a;统计指标收集器&#xff0c;比如平均值&#xff0c;最大值&#xff0c;最小值PollingCounter&#xff1a;自定义统计指标收集器&#xff0c;通过自定义统计方法的方式实现对指标…

这9个人气超高的公众号,你还没关注吗?

有些人&#xff0c;生活离不开朋友圈朋友圈是他们展示自我、观察世界的一扇窗户而有些人&#xff0c;从来也不点开朋友圈他们更愿意利用地铁上的零散化时间看点有意义、有知识的公众号推送完成对自我知识库的更新今天为大家推荐以下优质订阅号Kindle杂志公社ID&#xff1a;Mag1…

客户要求ASP.NET Core API返回特定格式,怎么办?

当ASP.NET Core API提供给到外部系统使用时&#xff0c;在某些情况下&#xff0c;可能需要根据这些外部系统的要求来格式化数据。比如&#xff0c;客户就要求API的返回值属性名必须是PascalCase&#xff08;如UserName&#xff09;&#xff0c;但是这些API需要同时提供给内部系…

Ubuntu 12.04 x64 下安装 GStreamer+FFmpeg+Opencv

Ubuntu 12.04 x64 下安装 GStreamerFFmpegOpencv近期&#xff0c;因为安装这三个开发软件&#xff0c;搞编译环境&#xff0c;上网找方法&#xff0c;足足耗费了我一个多星期的时间&#xff0c;现在将经验记录一下&#xff0c;在虚拟机和实体机上亲测成功安装。总流程&#xff…

html试题及答案,HTML试题及答案

A&#xff0e;照片、油画和一些细腻、讲求色彩浓淡的图片常采用JPEG格式B&#xff0e;JPEG支持很高的压缩率&#xff0c;因此其图像的下载速度非常快C&#xff0e;最高只能以256色显示的用户可能无法观看JPEG图像D&#xff0e;采用JPEG格式对图片进行压缩后&#xff0c;还能再打…

(转)程序员的十层楼11层(上帝)

第11层 上帝 看了上面的小标题&#xff0c;你可能会觉得奇怪&#xff0c;这篇文章不是讲“程序员的十层楼”吗&#xff1f;怎么冒出了第11层来了&#xff1f;其实这并不矛盾&#xff0c;程序员确实只有十层楼&#xff0c;因为爬到第11层时&#xff0c;已经变成上帝&#xff0c;…

史上最神奇的公式,竟然藏着这么多秘密!

全世界只有3.14 % 的人关注了青少年数学之旅前两天&#xff0c;我们的【欧拉公式—数学史上最强公式】数学经典文化衫首发众筹&#xff01;没想到短短几天时间文化衫就售罄了&#xff0c;其火爆程度远远超出了超模君的预期&#xff0c;甚至连不少“白嫖党”遇上这款文化衫后都情…

HiccDS共享音乐列表

Donet 第七组共享音乐列表200.7.7.18

html插入图片和文字,HTML第三课文字图片插入

HTML学习班第三课文字与图片的插入朋友们这一课我们一起来学习一下“文字与图片”的插入&#xff1a;一&#xff1a;首先我们先看一下插入文字的语法&#xff1a;例1&#xff1a;“朋友们好”这几个字的代码&#xff1a;朋友们好朋友们好说明&#xff1a;朋友们不难看出“朋友们…

Linux操作系统下Sudo命令的使用方法说明

“Sudo” 是Unix/Linux平台上的一个非常有用的工具&#xff0c;它允许系统管理员分配给普通用户一些合理的“权利”&#xff0c;让他们执行一些只有超级用户或其他特许用户才能完成的任务&#xff0c;比如&#xff1a;运行一些像mount&#xff0c;halt&#xff0c;su之类的命令…

Object C学习笔记11-数组

在Object C也提供了类似C#中的Array数组对象&#xff0c;在Object C中使用NSArray 来创建数组&#xff1b;但是在Object C中NSArray 只能存放对象类型的指针&#xff0c;不能存放int&#xff0c;char,double等基本数据类型。 一. 不可变数组对象 这个和之前的NSString有些类似&…

社区 正式发布了跨平台的 CoreWCF 0.2.0

在发布 CoreWCF 0.1.0 GA版本的半年之后&#xff0c;今天正式发布了0.2.0 版本&#xff0c;具体说明参看 https://github.com/CoreWCF/CoreWCF/releases/tag/v0.2.0 .NET 兼容性此版本依赖于 .NET Standard 2.0&#xff0c;可在支持 .NET Standard 2.0 的任何 .NET 版本上运行。…

你是不是在混日子,看着一点就知道了

全世界只有3.14 % 的人关注了青少年数学之旅2019已经进入倒计时了&#xff0c;年初立下的flag倒了几个&#xff1f;史蒂夫马丁有一句话&#xff1a;“所有的人生谜语都可以从阅读中找到答案。”无论是读影评、读好书&#xff0c;亦或者涉猎趣闻轶事、汲取犀利观点&#xff0c;总…