c#异步编程

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› c#›C#教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

原文链接：https://blog.csdn.net/zuheyawen/article/details/99863588

前言
C#异步编程有几种实现方式，异步方法就是其中的一种。异步方法是 C#5.0 才有的新特性，主要采用 async、await 关键字声明为异步方法，完成对方法的异步调用。C#5.0 对应的 VS 版本是 VS2012，对应的 .NET Framework 版本是 v4.5，所以需要在此基础上才支持。（否则可能报：找不到“async”修饰符所需的所有类型。目标框架版本是否不正确，或者缺少对程序集的引用?）

什么是异步方法
1. 异步方法，是指在执行当前方法的同时，可以异步的去调用其他方法（异步方法），并且不会阻塞当前方法的线程。
2. 使用了 async 修饰符的方法称为异步方法，通常配合 await 运算符和 Task 异步任务一起使用。
1) 如果方法使用了 async 修饰符，则方法中需要包含一个以上 await 运算符，否则将以同步执行。
2) 反之，如果方法中包含一个以上 await 运算符，则必须声明为一个异步方法，即使用 async 修饰符。

3. Task 分为两种：
1) Task，表示可以执行一个异步操作，声明如下：
public class Task : IAsyncResult, IDisposable { }
2) Task<TResult>，表示可以执行带有返回值的异步操作，声明如下：
public class Task<TResult> : Task { }

4. 异步方法的返回类型必须为 void、Task、Task<TResult> 中的其中一种。
1) void，表示无返回值，不关心异步方法执行后的结果，一般用于仅仅执行某一项任务，但是不关心结果的场景。
2) Task，表示异步方法将返回一个 Task 对象，该对象通常用于判断异步任务是否已经完成，可以使用 taskObj.Wait() 方法等待，或者 taskObj.IsCompleted 判断。
3) Task<TResult>，表示异步方法将返回一个 Task<TResult> 对象，该对象的 Result 属性则是异步方法的执行结果，调用该属性时将阻塞当前线程（异步方法未执行完成时）。

归纳一下：void 不关心结果；Task 只关心是否执行完成；Task<TResult> 不止关心是否执行完成，还要获取执行结果。

下面通过几个生活中比较形象的例子来理解异步方法的使用
1. 模拟扔垃圾（不关心结果，返回 void 类型）

/// <summary>
/// 扔垃圾
/// </summary>
public void DropLitter()
{
    Console.WriteLine("老婆开始打扫房间，线程Id为：{0}", GetThreadId());
    Console.WriteLine("垃圾满了，快去扔垃圾");
    CommandDropLitter();
    Console.WriteLine("不管他继续打扫，线程Id为：{0}", GetThreadId());
    Thread.Sleep(100);
    Console.WriteLine("老婆把房间打扫好了，线程Id为：{0}", GetThreadId());
}
 
/// <summary>
/// 通知我去扔垃圾
/// </summary>
public async void CommandDropLitter()
{
    Console.WriteLine("这时我准备去扔垃圾，线程Id为：{0}", GetThreadId());
    await Task.Run(() =>
    {
        Console.WriteLine("屁颠屁颠的去扔垃圾，线程Id为：{0}", GetThreadId());
        Thread.Sleep(1000);
    });
    Console.WriteLine("垃圾扔了还有啥吩咐，线程Id为：{0}", GetThreadId());
}

运行以上代码：

以上代码在 CommandDropLitter() 方法上加了 async 修饰符，并且使用 await 运算符开启了一个新的 Task 去执行另一个任务。注意：当前线程遇到 await 时，则立刻跳回调用方法继续往下执行。而 Task 执行完成之后将执行 await 之后的代码，并且与 await 之前的线程不是同一个。

2.模拟打开电源开关（关心是否执行完成，返回 Task 类型）

/// <summary>
/// 打开电源开关
/// </summary>
public void OpenMainsSwitch()
{
    Console.WriteLine("我和老婆正在看电视，线程Id为：{0}", GetThreadId());
    Console.WriteLine("突然停电了，快去看下是不是跳闸了");
    Task task = CommandOpenMainsSwitch();
    Console.WriteLine("没电了先玩会儿手机吧，线程Id为：{0}", GetThreadId());
    Thread.Sleep(100);
    Console.WriteLine("手机也没电了只等电源打开，线程Id为：{0}", GetThreadId());
 
    //task.Wait();    //所以这里将被阻塞，直到任务完成
    //或者
    while (!task.IsCompleted) { Thread.Sleep(100); }
 
    Console.WriteLine("又有电了我们继续看电视，线程Id为：{0}", GetThreadId());
}
 
/// <summary>
/// 通知我去打开电源开关
/// </summary>
public async Task CommandOpenMainsSwitch()
{
    Console.WriteLine("这时我准备去打开电源开关，线程Id为：{0}", GetThreadId());
    await Task.Run(() =>
    {
        Console.WriteLine("屁颠屁颠的去打开电源开关，线程Id为：{0}", GetThreadId());
        Thread.Sleep(1000);
    });
 
    Console.WriteLine("电源开关打开了，线程Id为：{0}", GetThreadId());
}

运行以上代码：

1) 可见，调用 Wait() 方法后，当前线程被阻塞了，直到 Task 执行完成后，当前线程才继续执行。
2) 注意：由于 CommandOpenMainsSwitch() 是一个异步方法，虽然返回类型为 Task 类型，但是在我们代码中并没有写（也不能写） return task 语句，这是为什么呢？可能是这种返回类型比较特殊，或者编译器自动帮我们完成了吧！就算写也只能写 return 语句，后面不能跟对象表达式。

3. 模拟去买盐（不止关心是否执行完成，还要获取执行结果。返回 Task<TResult> 类型）

/// <summary>
/// 做饭
/// </summary>
public void CookDinner()
{
    Console.WriteLine("老婆开始做饭，线程Id为：{0}", GetThreadId());
    Console.WriteLine("哎呀，没盐了");
    Task<string> task = CommandBuySalt();
    Console.WriteLine("不管他继续炒菜，线程Id为：{0}", GetThreadId());
    Thread.Sleep(100);
    string result = task.Result;    //必须要用盐了，等我把盐回来（停止炒菜（阻塞线程））
    Console.WriteLine("用了盐炒的菜就是好吃【{0}】，线程Id为：{1}", result, GetThreadId());
    Console.WriteLine("老婆把饭做好了，线程Id为：{0}", GetThreadId());
}
 
/// <summary>
/// 通知我去买盐
/// </summary>
public async Task<string> CommandBuySalt()
{
    Console.WriteLine("这时我准备去买盐了，线程Id为：{0}", GetThreadId());
 
    string result = await Task.Run(() =>
    {
        Console.WriteLine("屁颠屁颠的去买盐，线程Id为：{0}", GetThreadId());
        Thread.Sleep(1000);
        return "盐买回来了，顺便我还买了一包烟";
 
    });
 
    Console.WriteLine("{0}，线程Id为：{1}", result, GetThreadId());
 
    return result;
}

运行以上代码：

1) 以上代码 task.Result 会阻塞当前线程，与 task.Wait() 类似。
2) 注意：与前面返回类型为 Task 的 CommandOpenMainsSwitch() 方法一样，虽然 CommandBuySalt() 方法返回类型为 Task<string>，但是我们的返回语句是 return 字符串。

其他示例
1. 在前面（模拟去买盐）的示例中，异步方法中只开启了一个 Task，如果开启多个 Task 又是什么情况，看代码：

public void AsyncTest()
{
    Console.WriteLine("AsyncTest() 方法开始执行，线程Id为：{0}", GetThreadId());
    Task task = Test1();
    Console.WriteLine("AsyncTest() 方法继续执行，线程Id为：{0}", GetThreadId());
    task.Wait();
    Console.WriteLine("AsyncTest() 方法结束执行，线程Id为：{0}", GetThreadId());
}
 
public async Task Test1()
{
    Console.WriteLine("Test1() 方法开始执行，线程Id为：{0}", GetThreadId());
    await Task.Factory.StartNew((state) =>
    {
        Console.WriteLine("Test1() 方法中的 {0} 开始执行，线程Id为：{1}", state, GetThreadId());
        Thread.Sleep(1000);
        Console.WriteLine("Test1() 方法中的 {0} 结束执行，线程Id为：{1}", state, GetThreadId());
    }, "task1");
 
    await Task.Factory.StartNew((state) =>
    {
        Console.WriteLine("Test1() 方法中的 {0} 开始执行，线程Id为：{1}", state, GetThreadId());
        Thread.Sleep(3000);
        Console.WriteLine("Test1() 方法中的 {0} 结束执行，线程Id为：{1}", state, GetThreadId());
    }, "task2");
 
    Console.WriteLine("Test1() 方法结束执行，线程Id为：{0}", GetThreadId());
}

运行以上代码：

当异步方法中有多个 await 时，会依次执行所有的 Task，只有当所有 Task 执行完成后才表示异步方法执行完成，当前线程才得以执行。

2. 同样以前面（模拟去买盐）的示例，如果发现其实家里还有盐，这是就要告诉我不用买了（取消异步操作），怎么实现？这就要借助 System.Threading.CancellationTokenSource 和 System.Threading.Tasks.CancellationToken 对象来完成。

/// <summary>
/// 做饭（买盐任务取消）
/// </summary>
public void CookDinner_CancelBuySalt()
{
    Console.WriteLine("老婆开始做饭，线程Id为：{0}", GetThreadId());
    Console.WriteLine("哎呀，没盐了");
    CancellationTokenSource source = new CancellationTokenSource();
    Task<string> task = CommandBuySalt_CancelBuySalt(source.Token);
    Console.WriteLine("不管他继续炒菜，线程Id为：{0}", GetThreadId());
    Thread.Sleep(100);
 
    string result = "家里的盐";
    if (!string.IsNullOrEmpty(result))
    {
        source.Cancel();    //传达取消请求
        Console.WriteLine("家里还有盐不用买啦，线程Id为：{0}", GetThreadId());
    }
    else
    {
        //如果已取消就不能再获得结果了（否则将抛出 System.Threading.Tasks.TaskCanceledException 异常）
        //你都叫我不要买了，我拿什么给你？
        result = task.Result;
    }
 
    Console.WriteLine("既然有盐我就继续炒菜【{0}】，线程Id为：{1}", result, GetThreadId());
    Console.WriteLine("老婆把饭做好了，线程Id为：{0}", GetThreadId());
    Console.WriteLine("最终的任务状态是：{0}，已完成：{1}，已取消：{2}，已失败：{3}",
        task.Status, task.IsCompleted, task.IsCanceled, task.IsFaulted);
}
 
/// <summary>
/// 通知我去买盐（又告诉我不用买了）
/// </summary>
public async Task<string> CommandBuySalt_CancelBuySalt(CancellationToken token)
{
    Console.WriteLine("这时我准备去买盐了，线程Id为：{0}", GetThreadId());
 
    //已开始执行的任务不能被取消
    string result = await Task.Run(() =>
    {
        Console.WriteLine("屁颠屁颠的去买盐，线程Id为：{0}", GetThreadId());
        Thread.Sleep(1000);
    }, token).ContinueWith((t) =>  //若没有取消就继续执行
    {
        Console.WriteLine("盐已经买好了，线程Id为：{0}", GetThreadId());
        Thread.Sleep(1000);
 
        return "盐买回来了，顺便我还买了一包烟";
    }, token);
 
    Console.WriteLine("{0}，线程Id为：{1}", result, GetThreadId());
 
    return result;
}

运行以上代码：

1) 刚开始我以为调用 source.Cancel() 方法后会立即取消 Task 的执行，仔细一想也不太可能。如果需要在 Task 执行前或者执行期间完成取消操作，我们自己写代码判断 cancellationToken.IsCancellationRequested 属性是否为 true（该属性在调用 source.Cancel() 后或者 source.CancelAfter() 方法到达指定时间后为 true），如果为 true 结束执行即可。
2) 这里所说的“传达取消请求”的意思是，每个 Task 在执行之前都会检查 cancellationToken.IsCancellationRequested 属性是否为 true，如果为 true 则不执行 Task，并将设置 Status、IsCompleted、IsCanceled 等。
3) 所以，在 Task 的源码中有这样一段代码

if (cancellationToken.IsCancellationRequested)
{
    // Fast path for an already-canceled cancellationToken
    this.InternalCancel(false);
}

3. 乘热打铁，我们再来看看多个 CancellationTokenSource 取消异步任务，以及注册取消后的回调委托方法，继续以（模拟去买盐）为例：

/// <summary>
/// 做饭（多个消息传达买盐任务取消）
/// </summary>
public void CookDinner_MultiCancelBuySalt()
{
    Console.WriteLine("老婆开始做饭，线程Id为：{0}", GetThreadId());
    Console.WriteLine("哎呀，没盐了");
    CancellationTokenSource source1 = new CancellationTokenSource();    //因为存在而取消
    CancellationTokenSource source2 = new CancellationTokenSource();    //因为放弃而取消
 
    CancellationTokenSource source = CancellationTokenSource.CreateLinkedTokenSource(source1.Token, source2.Token);
 
    //注册取消时的回调委托
    source1.Token.Register(() =>
    {
        Console.WriteLine("这是因为{0}所以取消，线程Id为：{1}", "家里还有盐", GetThreadId());
    });
 
    source2.Token.Register((state) =>
    {
        Console.WriteLine("这是因为{0}所以取消，线程Id为：{1}", state, GetThreadId());
    }, "不做了出去吃");
 
    source.Token.Register((state) =>
    {
        Console.WriteLine("这是因为{0}所以取消，线程Id为：{1}", state, GetThreadId());
    }, "没理由");
 
    //这里必须传递 CancellationTokenSource.CreateLinkedTokenSource() 方法返回的 Token 对象
    Task<string> task = CommandBuySalt_MultiCancelBuySalt(source.Token);
 
    Console.WriteLine("等等，好像不用买了，线程Id为：{0}", GetThreadId());
    Thread.Sleep(100);
 
    string[] results = new string[] { "家里的盐", "不做了出去吃", "没理由" };
    Random r = new Random();
    switch (r.Next(1, 4))
    {
        case 1:
            source1.Cancel();           //传达取消请求（家里有盐）
            //source1.CancelAfter(3000);  //3s后才调用取消的回调方法
            Console.WriteLine("既然有盐我就继续炒菜【{0}】，线程Id为：{1}", results[0], GetThreadId());
            break;
        case 2:
            source2.Cancel();           //传达取消请求（不做了出去吃）
            //source2.CancelAfter(3000);  //3s后才调用取消的回调方法
            Console.WriteLine("我们出去吃不用买啦【{0}】，线程Id为：{1}", results[1], GetThreadId());
            break;
        case 3:
            source.Cancel();            //传达取消请求（没理由）
            //source.CancelAfter(3000);   //3s后才调用取消的回调方法
            Console.WriteLine("没理由就是不用买啦【{0}】，线程Id为：{1}", results[2], GetThreadId());
            break;
    }
 
    Console.WriteLine("最终的任务状态是：{0}，已完成：{1}，已取消：{2}，已失败：{3}",
        task.Status, task.IsCompleted, task.IsCanceled, task.IsFaulted);
}
 
/// <summary>
/// 通知我去买盐（又告诉我不用买了，各种理由）
/// </summary>
public async Task<string> CommandBuySalt_MultiCancelBuySalt(CancellationToken token)
{
    Console.WriteLine("这时我准备去买盐了，线程Id为：{0}", GetThreadId());
 
    //已开始执行的任务不能被取消
    string result = await Task.Run(() =>
    {
        Console.WriteLine("屁颠屁颠的去买盐，线程Id为：{0}", GetThreadId());
        Thread.Sleep(1000);
    }, token).ContinueWith((t) =>  //若没有取消就继续执行
    {
        Console.WriteLine("盐已经买好了，线程Id为：{0}", GetThreadId());
        Thread.Sleep(1000);
        return "盐买回来了，顺便我还买了一包烟";
    }, token);
 
    Console.WriteLine("{0}，线程Id为：{1}", result, GetThreadId());
 
    return result;
}

运行以上代码：

1) 当调用 source.Cancel() 方法后，会立即取消并调用 token 注册的回调方法；而调用 existSource.CancelAfter() 方法则会等到达指定的毫秒数后才会取消。
2) 注意：传递给异步方法的 token 对象，必须是 CancellationTokenSource.CreateLinkedTokenSource() 方法返回的 Token 对象，否则取消将无效。
3) 回调的委托方法始终只有两个，一个是 CancellationTokenSource.CreateLinkedTokenSource() 方法返回的 Token 对象的注册委托，另一个是调用 Cancel()/CancelAfter() 方法的 Token 对象的注册委托。
4) 如果以上代码调用的是 CancelAfter(3000) 方法，运行结果如下：

原文链接：https://www.cnblogs.com/abeam/p/11227935.html

/// <summary>
/// 扔垃圾
/// </summary>
public void DropLitter()
{
Console.WriteLine("老婆开始打扫房间，线程Id为：{0}", GetThreadId());
Console.WriteLine("垃圾满了，快去扔垃圾");
CommandDropLitter();
Console.WriteLine("不管他继续打扫，线程Id为：{0}", GetThreadId());
Thread.Sleep(100);
Console.WriteLine("老婆把房间打扫好了，线程Id为：{0}", GetThreadId());
}
/// <summary>
/// 通知我去扔垃圾
/// </summary>
public async void CommandDropLitter()
{
Console.WriteLine("这时我准备去扔垃圾，线程Id为：{0}", GetThreadId());
await Task.Run(() =>
鲜花
握手
雷人
路过
鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

C#WinformTabControl双击关闭TabPage发布时间：2022-07-10

C#中的函数(三)参数传递及返回值发布时间：2022-07-10

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：19184|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9988|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8325|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8695|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8638|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9655|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8622|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7998|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8652|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7535|2022-11-06

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服

地址：深圳市南山区西丽大学城创智工业园

电邮：jeky_zhao#qq.com

移动电话：139-2527-9053

客服电话

电子邮件

c#异步编程

请发表评论

全部评论

上一篇：

下一篇：

CVE-2022-32051

jcabi/jcabi-maven-plugin: Supplementary

Maven Helper - IntelliJ IDEs Plugin | Ma

delphi 数据导出进度条自己生成

tradingview/charting-library-tutorial: T

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053

客服电话

电子邮件

c#异步编程

请发表评论

全部评论

上一篇：

下一篇：

CVE-2022-32051

jcabi/jcabi-maven-plugin: Supplementary

Maven Helper - IntelliJ IDEs Plugin | Ma

delphi 数据导出 进度条自己生成

tradingview/charting-library-tutorial: T

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053

delphi 数据导出进度条自己生成