C#异步使用需要注意的几个问题
目录
- 一、异步模型的基本概述
- 二、C#异步使用需要注意的几个问题
- 三、CancellationToken 结构体
- 1.手动取消
- 2.利用方法取消，抛出异常
- 3. 传参数取消
- 4.手动触发事件取消任务
- 5.Task类方法
- 6.yield流水线返回
一、异步模型的基本概述
异步编程的核心是 Task 和 Task<T> 对象，这两个对象对异步操作建模。 它们受关键字 async 和 await 的支持。 在大多数情况下模型十分简单：
对于 I/O 绑定代码，当你 await 一个操作，它将返回 async 方法中的一个 Task 或 Task<T> 。
对于 CPU 绑定代码，当你 await 一个操作，它将在后台线程通过 Task.Run() 方法启动。
二、C#异步使用需要注意的几个问题
- 异步方法如果只是对别的方法的简单的转发调用，没哟复杂的逻辑（比如等待A的结果，再调用B，等待A调用的返回值拿到内部做一些处理再返回），那么就可以去掉async关键字。
- 异步方法其实使用async 关键字clr多了一些准备和 转换的处理和线程的切换，效率反而低。
- 异步方法中想暂停一段时间，不要用thread.sleep(),因为他会阻塞调用线程导致当前界面卡无响应，而要用await task.delay(); 例如6秒后下载一个文件
- 异步中的CancellationToken 参数，用于提前终止任务，比如取消任务，请求超时
三、CancellationToken 结构体
- None 空
- bool IsCancellationToken 是否取消
- Register（action callback）注册取消监听
- ThrowIfCancellationRequested 如果任务被取消，执行到这句话就抛异常
- CancellationTokenSource 来创建 CancellationToken
- CancelAfter()超时后发出取消信号
- Cancel()发出取消信号
- CancellationToken Token
static async Task Main(string[] args)
{
CancellationTokenSource cts = new CancellationTokenSource();
cts.CancelAfter(5000); //超时5s后取消
await DownloadString("http://www.baidu.com", 50, cts.Token);
}
1.手动取消
if (cancellationToken.IsCancellationRequested)
{
Console.WriteLine("任务被取消");
break;
}
2.利用方法取消，抛出异常
cancellationToken.ThrowIfCancellationRequested();
3. 传参数取消
系统自带的异步方法，只需要传参数就可取消，抛出异常
var resp= await client.GetAsync(url,cancellationToken);
4.手动触发事件取消任务
static async Task Main(string[] args)
{
CancellationTokenSource cts = new CancellationTokenSource();
//cts.CancelAfter(5000);
DownloadString("http://www.baidu.com", 100, cts.Token); //和超时区别在于去掉了前面的await 才生效
while (Console.ReadLine() != "q")
{
}
cts.Cancel();
Console.ReadLine();
}
.Asp.net core Mvc 控制器里面的异步方法尽量带 CancellationToken
5.Task类方法
WhenAny任何一个Task完成，task就完成WhenAll所有任务都完成，才完成 。 不在乎Task执行顺序FromResult创建普通数值的Task对象
6.yield流水线返回
yield 可以流水线返回，提高性能。
C# 8.0以上支持 yield异步方法的使用
static async IAsyncenumerable<string> test()
{
yield return "a";
yield return "b";
yield return "c";
}
调用：
await foreach(var o in test())
{
Console.WriteLine(o);
}
public static async Task DownloadString(string url,int num,CancellationToken cancellationToken)
{
try
{
using (var client = new HttpClient())
{
for (int i = 0; i < num; i++)
{
string html = await client.GetStringAsync(url);
Console.WriteLine($"{DateTime.Now}:{html}");
//1.手动取消
if (cancellationToken.IsCancellationRequested)
{
Console.WriteLine("任务被取消");
break;
}
//2.抛出异常
//cancellationToken.ThrowIfCancellationRequested();
}
}
}
catch (Exception)
{
throw;
}
}
public static async Task Download2String(string url, int num, CancellationToken cancellationToken)
{
using (var client = new HttpClient())
{
for (int i = 0; i < num; i++)
{
var resp= await client.GetAsync(url,cancellationToken);
string html =await resp.Content.ReadAsStringAsync();
Console.WriteLine($"{DateTime.Now}:{html}");
//1.手动取消
//if (cancellationToken.IsCancellationRequested)
//{
// Console.WriteLine("任务被取消");
// break;
//}
//2.抛出异常
//cancellationToken.ThrowIfCancellationRequested();
}
}
}
到此这篇关于C#使用异步需要注意的几个问题的文章就介绍到这了,更多相关C#使用异步需要注意的问题内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！
相关推荐
-
C#异步的世界(上)
前言 新进阶的程序员可能对async.await用得比较多,却对之前的异步了解甚少.本人就是此类,因此打算回顾学习下异步的进化史. 本文主要是回顾async异步模式之前的异步,下篇文章再来重点分析async异步模式. APM APM 异步编程模型,Asynchronous Programming Model 早在C#1的时候就有了APM.虽然不是很熟悉,但是多少还是见过的.就是那些类是BeginXXX和EndXXX的方法,且BeginXXX返回值是IAsyncResult接口. 在正式写APM示
-
c# 在Emit代码中如何await一个异步方法
0. 前言 首先立马解释一波为啥会有这样一篇伪标题的Demo随笔呢? 不是本人有知识误区,或者要误人子弟 因为大家都知道emit写出来的都是同步方法,不可能await,至少现在这么多年来没有提供对应的功能 这是之前某天在微信群看见讨论怎么emit一个异步方法并包装异步结构,简单几句文字也未能清晰的表达 所以趁着元旦节放假有点时间, 简单列举三种我知道方式去达到这样的效果 三种方法都是绕过emit直接书写emit代码,而是将对应逻辑转到其他方法中,最后emit调用方法达到效果 Demo 说明 原始
-
c# 异步编程入门
一.什么算异步? 广义来讲,两个工作流能同时进行就算异步,例如,CPU与外设之间的工作流就是异步的.在面向服务的系统中,各个子系统之间通信一般都是异步的,例如,订单系统与支付系统之间的通信是异步的,又如,在现实生活中,你去馆子吃饭,工作流是这样的,点菜->下单->做你的事->上菜->吃饭,这个也是异步的,具体来讲你和厨师之间是异步的,异步是如此重要,因外它代表者高效率(两者或两者以上的工作可以同时进行),但复杂,同步的世界简单,但效率极极低. 二.在编程中的异步 在编程中,
-
C#异步编程几点需要注意的地方
尽量不要编写返回值类型为void的异步方法 在通常情况下,建议大家不要编写那种返回值类型为void的异步方法,因为这样做会破坏该方法的启动者与方法本身之间的约定,这套约定本来可以确保主调方能够捕获到异步方法所发生的异常. 正常的异步方法是通过它返回的Task对象来汇报异常的.如果执行过程中发生了异常,那么Task对象就进入了faulted(故障)状态.主调方在对异步方法所返回的Task对象做await操作时,该对象若已处在faulted状态,系统则会将执行异步方法的过程中所发生的异常抛出,反之,
-
C#异步的世界(下)
前言 今天说异步的主要是指C#5的async\await异步.在此为了方便的表述,我们称async\await之前的异步为"旧异步",async\await为"新异步". 新异步的使用 只能说新异步的使用太简单(如果仅仅只是说使用) 方法加上async修饰符,然后使用await关键字执行异步方法,即可.对就是如此简单.像使用同步方法逻辑一样使用异步. public async Task<int> Test() { var num1 = await Get
-
c# 异步编程基础讲解
现代应用程序广泛使用文件和网络 I/O.I/O 相关 API 传统上默认是阻塞的,导致用户体验和硬件利用率不佳,此类问题的学习和编码的难度也较大.而今基于 Task 的异步 API 和语言级异步编程模式颠覆了传统模式,使得异步编程非常简单,几乎没有新的概念需要学习. 异步代码有如下特点: 在等待 I/O 请求返回的过程中,通过让出线程来处理更多的服务器请求. 通过在等待 I/O 请求时让出线程进行 UI 交互,并将长期运行的工作过渡到其他 CPU,使用户界面的响应性更强. 许多较新的 .NET
-
c# 几个常见的TAP异步操作
在本系列上一篇文章 [15:异步编程基础] 中,我们讲到,现代应用程序广泛使用的是基于任务的异步编程模式(TAP),历史的 EAP 和 AMP 模式已经过时不推荐使用.今天继续总结一下 TAP 的异步操作,比如取消任务.报告进度.Task.Yield().ConfigureAwait() 和并行操作等. 虽然实际 TAP 编程中很少使用到任务的状态,但它是很多 TAP 操作机理的基础,所以下面先从任务状态讲起. 1 任务状态 Task 类为异步操作提供了一个生命周期,这个周期由 TaskStat
-
C#如何使用Task执行异步操作
为什么要使用 Task 线程是创建并发的底层工具,因此具有一定的局限性. 没有简单的方法可以从联合(Join)线程得到"返回值".因此必须创建一些共享域.当抛出一个异常时,捕捉和处理异常也是麻烦的. 线程完成之后,无法再次启动该线程.相反,只能联合(Join)它(在进程阻塞当前线程). 任务是可组合的--使用延续将它们串联在一起.它们可以使用线程池减少启动延迟,而且它们可以通过TaskCompletionSource使用回调方法,避免多个线程同时等待I/O密集操作. Task 和 Th
-
C#异步迭代IAsyncEnumerable应用实现
最近用WPF做金税盘开发中有这样一个需求,批量开票每次开票都需要连接一次金税盘. 比如我有发票 a, b ,c ,d e 这五张发票,每次开具发票都需要调用金税盘底层,才能正常开票. 首先,尝试写第一个方法 private void Button_Click(object sender, RoutedEventArgs e) { var dateStart = DateTime.Now; //记录用时的起始时间 DebugText = string.Empty; List<string> fp
-
原生JavaScrpit中异步请求Ajax实现方法
在前端页面开发的过程中,经常使用到Ajax请求,异步提交表单数据,或者异步刷新页面. 一般来说,使用Jquery中的$.ajax,$.post,$.getJSON,非常方便,但是有的时候,我们只因为需要ajax功能而引入Jquery比较不划算. 所以接下来便用原生JavaScrpit实现一个简单的Ajax请求,并说明ajax请求中的跨域访问问题,以及多个ajax请求的数据同步问题. JavaScript实现Ajax异步请求 简单的ajax请求实现 Ajax请求的原理是创建一个XMLHttpReq
-
四步轻松实现ajax发送异步请求
ajax发送异步请求,供大家参考,具体内容如下 第一步(得到XMLHttpRequest) ajax其实只需要学习一个对象:XMLHttpRequest,如果掌握了它,就掌握了ajax!!! 1.得到XMLHttpRequest 大多数浏览器都支持:var xmlHttp=new XMLHttpRequest(); IE6.0:var xmlHttp=new ActiveXObject("Msxml2.XMLHTTP"); IE5.0以更早版本的IE:var xmlHttp=new A
-
学习YUI.Ext 第六天--关于树TreePanel(Part 2异步获取节点)
下面将介绍如何异步取一棵树的所有节点,具体做法与官方同步取节点有很大不同,尤其在json的id属性上,下面是我一些摸索,可能不是最佳方案,有待大家一起研究. 异步取节点的思路是这样的: 1.先定义一个初始化节点(也可以不定义,看个人需求) 2.yui-ext根据该节点id请求服务器,获得子节点各属性 3.循环 特点:可以在上一级目录中,在服务器端预先将该节点是否有子节点读好(json中的isLeaf属性),虽然但数据库将多承担一些压力,但用个count(*)不会造成太大负担(除非查询条件异常复杂
-
jquery select插件异步实时搜索实例代码
一.先看看效果. 二.做此插件的原因. 1.数据量过大(几千.几万条),无法一次性全部加载. 2.现有插件各不相同,无法满足功能需求. 3.美观性,可控性不足. 三.如何使用. 1.html和js <select id="unit"></select> <script type="text/javascript" src="/demo/thirdparty/jquery/jquery-1.8.3.min.js">
-
extJS中常用的4种Ajax异步提交方式
/** 复制代码 代码如下: * 第一种Ajax提交方式 * 这种方式需要直接使用ext Ajax方法进行提交 * 使用这种方式,需要将待传递的参数进行封装 * @return */ function saveUser_ajaxSubmit1() { Ext.Ajax.request( { url : 'user_save.action', method : 'post', params : { userName : document.getElementById('userName').val
-
dojo学习第二天 ajax异步请求之绑定列表
用户不喜欢滚动条,于是我们做成了选项卡切换,用户不喜欢刷新页面,于是我们就要使用ajax了,前些年,几乎每个web端开发人员,都以懂得一点点ajax而自豪,但知道使用ajax是远远不够的,因为技术是为人而服务的,不能滥用技术,你总不能为了验证一个文本框textbox而去异步请求一次.我还遇到过有人,更新用户信息的时候,使用ajax更新,用户信息中的图片,又使用回发来更新,一个更新中,先ajax卡在那,然后再回发,你说这是多么2的行为?这种人还不少,我还遇到过有人用ajax更新后再location
-
原生javascript实现文件异步上传的实例讲解
效果图: 代码:(demo33.jsp) <%@ page contentType="text/html;charset=UTF-8" language="java" %> <html> <head> <title>demo33.jsp</title> </head> <body> <label for="text">名称</label>
-
详解angularjs利用ui-route异步加载组件
ui-route相比于angularjs的原生视图路由更好地支持了路由嵌套,状态转移等等.随着视图不断增加,打包的js体积也会越来越大,比如我在应用里面用到了wangeditor里面单独依赖的jquery就300多k.异步加载各个组件就很有必要.在这里我就以ui-route为框架来进行异步加载说明. 首先看一下路由加载文件 angular.module('webtrn-sns').config(['$stateProvider', function ($stateProvider) { $sta
-
Angularjs的$http异步删除数据详解及实例
Angularjs的$http异步删除数据详解及实例 有人会说删除这东西有什么可讲的,写个删除的service,controller调用一下不就完了. 嗯...看起来是这样,但是具体实现起来真的有这么简单吗?首先有以下几个坑 怎么确定数据是否删除成功? 怎么同步视图的数据库的内容? 1.思路 1.实现方式一 删除数据库中对应的内容,然后将$scope中的对应的内容splice 2.实现方式二 删除数据库中对应的内容,然后再reload一下数据(也就是再调用一次查询方法,这种消耗可想而知,并且还要
-
详解Angular.js的$q.defer()服务异步处理
首先本文以个人目前项目的部分代码为例说明为什么要用deferred. function getBase64(img){//传入图片路径,返回base64 function getBase64Image(img,width,height) { var canvas = document.createElement("canvas"); canvas.width = width ? width : img.width; canvas.height = height ? height : i