异步流使用注意事项

异步流是C#8.0出来的特性,可以让流式数据以尽快分批的方式返回,而不像之前那样,当全部获取到数据后,再返回。

下面的例子的场景有点特殊,查询一个较多的数据,为了查询不给数据带来很大压力,做成一个分批从数据查询回数据,组装成一个整理List返回。

如果是之前的做法,就需要等所有的数据返回后,累加到一个集合中,然后返回;如果用异步流,可以返回一批,就返回,以便更快的让使用者展示或使用。

异步流也有问题,多次返回,虽然用户体验相对好一些,但用时更长,通过下面的例子可以了解到。

using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;
using System.Net.WebSockets;
using System.Text;
using System.Threading.Tasks;
using System.Diagnostics;
using System.Security.Cryptography;
using System.IO;
using Dapper;namespace KeyWordsDemo
{class AsyncStreamDemo : IDemoAsync{public async Task RunAsync(){Console.WriteLine("1、异常流  2、同步获取")var no = Console.ReadLine();var producer = new Producer();if(no == "1"){var watch = new Stopwatch();watch.Start();await foreach (var orders in producer.EnumerateOrdersAsync()){foreach (var order in orders){Console.WriteLine(order.ToString());}}watch.Stop();Console.Title = $"时长:{ watch.Elapsed.TotalSeconds}";}else{var watch = new Stopwatch();watch.Start();var orders = await producer.GetOrdersAsync();foreach (var order in orders){Console.WriteLine(order.ToString());}watch.Stop();Console.Title = $"获取到数据:{orders.Count()} 时长:{ watch.Elapsed.TotalSeconds}";}Console.ReadLine();}}class Producer{public async Task<List<SalesOrderDetail>> GetOrdersAsync(){var orders = new List<SalesOrderDetail>();var offset = 0;while (true){var list = (await QueryOrdersAsync(offset)).ToList();orders.AddRange(list);offset++;if (list.Count < 100){break;}}return orders;}public async IAsyncEnumerable<List<SalesOrderDetail>> EnumerateOrdersAsync(){var offset = 0;while (true){var list = (await QueryOrdersAsync(offset)).ToList();yield return list;offset++;if (list.Count < 100){break;}}}public async Task<IEnumerable<SalesOrderDetail>> QueryOrdersAsync(int offset){using var con = new SqlConnection("server=.;database=AdventureWorks2016;uid=sa;pwd=sa;");var sql = @$"select * from Sales.SalesOrderDetail order by SalesOrderID,SalesOrderDetailID  offset {offset * 100} row fetch next 100 row only";return await con.QueryAsync<SalesOrderDetail>(sql);}}class SalesOrderDetail{public int SalesOrderID { get; set; }public string CarrierTrackingNumber { get; set; }public short OrderQty { get; set; }public int ProductID { get; set; }public int SpecialOfferID { get; set; }public decimal UnitPrice { get; set; }public decimal UnitPriceDiscount { get; set; }public Guid rowguid { get; set; }public DateTime ModifiedDate { get; set; }public override string ToString(){return System.Text.Json.JsonSerializer.Serialize(this);}}
}

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

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

相关文章

python类库32[多线程同步Lock+RLock+Semaphore+Event]

2019独角兽企业重金招聘Python工程师标准>>> 一 多线程同步 由于CPython的python解释器在单线程模式下执行&#xff0c;所以导致python的多线程在很多的时候并不能很好地发挥多核cpu的资源。大部分情况都推荐使用多进程。 python的多线程的同步与其他语言基本相同…

加个ing是什么意思_take的意思竟然是“要求”?奇奇怪怪的熟词僻义打卡终于来了!...

慢慢来&#xff0c;比较快。只要不喊停&#xff0c;我们就继续。考研人被玩坏了&#xff0c;出题人&#xff1a;只要我不承认&#xff0c;就没有人能阻止我。下面盘点一下出题人的x操作&#xff1a;2020年英语二完形&#xff1a;trying&#xff0c;乍一看是不是和“尝试”有关&…

每日一笑 | 今天是植树节,我想在你心里种点逼树

全世界只有3.14 % 的人关注了数据与算法之美&#xff08;图片来源于网络&#xff0c;侵权删&#xff09;

怎么用计算机计算出选手最后得分,WPS技巧:TRIMMEAN函数计算选手得分

如图1就是某大奖赛的选手评分情况表。在“最后得分”一项中&#xff0c;我们可以用LARGE函数或SMALL函数来计算&#xff0c;如在J3中输入下面的公式&#xff1a;AVERAGE(LARGE(B3:I3,{2,3,4,5,6,7}))即可以得到正确的结果。这里&#xff0c;我们介绍ET提供的内部平均值函数——…

Windows 程序包管理器 1.0 正式发布

在 Microsoft Build 2021 开发者大会上&#xff0c;微软正式发布 Windows Package Manager&#xff08;程序包管理器&#xff09;1.0 正式版&#xff0c;目前在 GitHub 上已有超过 1600 个程序包可供下载。Windows 程序包管理器是一个综合的程序包管理器解决方案&#xff0c;由…

mindray心电监护仪使用说明_怎么看监护仪上的参数

血压病人的饮食治疗&#xff0c;是以减少钠盐、减少膳食脂肪并补充适量优质蛋白&#xff0c;注意补充钙和钾&#xff0c;多吃蔬菜和水果、戒烟戒酒、科学饮水为原则。①饮食宜清淡&#xff1a;提倡素食为主&#xff0c;素食方式可使高血压患者血压降低。因此高血压患者饮食宜清…

围棋天才柯洁怒怼央视国际记者,用实力斩获清华大学免试资格

全世界只有3.14 % 的人关注了数据与算法之美3月10 日&#xff0c;国家体育总局发布了《2019年优秀运动员免试入学推荐名单》&#xff0c;一批在体育领域获得亮眼成就的运动员们&#xff0c;将获得中国各所高校的免试入学机会。在名单上&#xff0c;数据汪找到一个熟悉的名字——…

sql按拼音排序

sql按拼音排序 sql按拼音排序select * from user order by name collate Chinese_PRC_CS_AS_KS_WS二.排序规则简介&#xff1a; 什么叫排序规则呢&#xff1f;ms是这样描述的&#xff1a;"在 microsoft sql server 2000 中&#xff0c;字符串的物理存储由排序规则控制。…

计算机专业杀毒,计算机病毒查杀

面对计算机病毒日益剧增&#xff0c;普通人的电脑中病毒的几率越来越大&#xff0c;学习几招查杀病毒的方法&#xff0c;有助于保持系统安全运行也避免一些不必要的损失。下面是学习啦小编跟大家分享的是计算机病毒查杀&#xff0c;欢迎大家来阅读学习。计算机病毒查杀步骤/方法…

Azure 上的网站如何识别不同国家和地区的用户

点击上方蓝字关注“汪宇杰博客”导语跨国服务的网站通常需要针对不同国家和地区的用户显示不同的内容。通常我们会根据用户的IP地址识别Ta所在的国家和地区&#xff0c;而自己编写代码以及购买和维护IP数据库&#xff0c;或使用三方的IP数据服务&#xff0c;是潜在的996成本。虽…

中小学不得在校内设置食品经营场所,量子摩尔定律问世,美团运营摩拜亏45亿,英伟达史上最大手笔收购,这就是今天的大新闻。...

今天是3月12日农历二月初六今天星期二去吃饭老板问要饭的吗一兄弟说我要饭的我要饭怎么觉得这对话有点怪怪下面是今天的大新闻中小学不得在校内设置食品经营场所&#xff08;中国新闻网&#xff09;据教育部网站消息&#xff0c;由教育部、国家市场监督管理总局、国家卫生健康委…

轮廓处理函数详细

ApproxChains用多边形曲线逼近 Freeman 链 CvSeq* cvApproxChains( CvSeq* src_seq, CvMemStorage* storage, int methodCV_CHAIN_APPROX_SIMPLE, double parameter0, int minimal_perimeter0, int recursive0 ); src_seq涉及其它链的链指针storage存储多边形线段位置的缓存m…

html5与课程思政,“课程思政”怎样做

&#xff3b;本站讯 ]为了提升学校教师的课程思政意识和课程思政建设水平,提高课程思政优秀案例征集水平,5月21日,教学促进与教师发展中心举办了课程思政专题线上分享会.中心主任张树永出席会议,120位教师通过雨课堂参加了直播活动.“课程思政”怎样做&#xff1f;教学案例设计…

Windows 11 快速体验:开始菜单居中,全系圆角设计!

系统类型&#xff1a;Windows 11 专业工作站版 系统版本&#xff1a;Dev系统版本号&#xff1a;OS Build 21996.1任务栏 Windows 11 任务栏上的“开始”菜单和应用程序图标由此前 Windows 操作系统中的“左对齐”样式变为“居中”。如果你不喜欢“居中”可以通过个性化设置更改…

puppeteer 鼠标定位滑块_监听滑块滑动或滑块随鼠标移动 | JShare

监听滑块滑动或滑块随鼠标移动 | JSharefork from "Column with rotated labels"var data [29,12,32,28,22,34,9,12,13,21,24,32,27,31,32,16,21,18,20];drawAdvChart();function drawAdvChart() {var option {chart : {type : column,renderTo : "container&…

数学建模,还得这样学!

最近天气逐渐晴朗回温&#xff08;伊芙布德干内库毛德川状态暂时告一阶段&#xff09;&#xff0c;数学建模的热度也在逐步回温&#xff08;据说大家开始了数学建模知识储备&#xff09;&#xff0c;常有小伙伴私聊小天咨询关于数学建模的事情。春节假期也已经过去&#xff0c;…

如何给远程计算机添加用户,如何访问远程计算机以添加/删除/管理用户帐户?...

我有一个场景&#xff0c;我需要访问远程计算机以编程方式添加和删除Windows用户帐户 . 远程机器是一个“备用工作站”&#xff0c;我需要远程配置&#xff0c;准备好以防万一主工作站需要更换 - 所以这里没有安全绕过或恶意软件:)我知道远程机器管理员的用户/密码&#xff0c;…

测试Live Writer 发表博客

2019独角兽企业重金招聘Python工程师标准>>> 测试成功&#xff01;&#xff01;&#xff01; 转载于:https://my.oschina.net/bonelwh/blog/125845

WPF 菜单栏滚动到顶部后固定的两种方法

最近项目中有这么个需求&#xff1a;菜单栏滚动到顶部后固定在顶部&#xff0c;专业的名词叫吸顶。。这在移动端还是比较常见的。看看效果&#xff1a;下面直接看看代码喽&#xff0c;代码不多&#xff1a;第一种方法思路&#xff1a;写一个和菜单一模一样的菜单&#xff0c;放…

eeprom 数据偶尔变成ff_关于水电站冗余配置下监控系统下发调节令偶尔不动作的案例分析...

点击上方“E小水电”&#xff0c;“星标或置顶公众号”关键时刻&#xff0c;第一时间送达摘要&#xff1a;吉勒布拉克水电站冗余配置下机组PLC组网运行&#xff0c;后台监控系统下发调节令&#xff0c;调节不动作或偶尔动作现象分析。引言吉勒布拉克机组自动化控制为冗余主备双…