您的位置：首页 > 编程技术 > csharp  >  .NET中的async和await关键字使用及Task异步调用实例

.NET中的async和await关键字使用及Task异步调用实例

 更新时间：2020年6月25日 11:36  点击：2166

其实早在.NET 4.5的时候M$就在.NET中引入了async和await关键字（VB为Async和Await）来简化异步调用的编程模式。我也早就体验过了，现在写一篇日志来记录一下顺便凑日志数量（以后面试之前可以用这个“复习”一下）。

（一）传统的异步调用

在比较“古老”的C#程序中经常可以看到IAsyncResult、BeginInvoke之类的异步调用“踪迹”。先来简单的复习一下吧。

假如我们有一个方法生成字符串，而生成这个字符串需要10秒中的时间：

复制代码 代码如下:

public class WasteTimeObject
{
    public string GetSlowString(int begin, int length)
    {
        StringBuilder sb = new StringBuilder();

        for (int i = begin; i < begin + length; i++)
        {
            sb.Append(WasteTime(i) + " ");
        }

        return sb.ToString();
    }

    private string WasteTime(int current)
    {
        System.Threading.Thread.Sleep(1000);
        return current.ToString();
    }
}

我们再做一个窗口，用来请求这个方法并把字符串显示到文本框中。使用同步调用肯定会把UI线程阻塞掉，要想不把UI阻塞掉就要另起一个线程了。基本的步骤如下：

创建一个异步调用的委托：

复制代码 代码如下:

public delegate string GetSlowStringDelegate(int begin, int length);

然后呢，再异步调用这个委托：

复制代码 代码如下:

private void button1_Click(object sender, EventArgs e)
{
    WasteTimeObject ad = new WasteTimeObject();
    GetSlowStringDelegate d = ad.GetSlowString;

    textBox1.Text = "Requesting string, please wait...";

    IAsyncResult ar = d.BeginInvoke(1, 10, TaskComplete, d);
}

这里的BeginInvoke会在原来的基础上再附加两个参数：表示执行完毕后的回调方法AsyncCallBack，最后一个参数可以是任何对象，以便从回调方法中访问它。不过一般情况都是传递的委托实例，以便获取调用的结果。

当然我们也可以不用回调方法，这样就只好不断地循环查询是否执行完成了。

然后我们就要编写AsyncCallBack这个回调方法了，它接受一个IAsyncResult类型的对象表示异步调用的结果：

复制代码 代码如下:

private void TaskComplete(IAsyncResult ar)
{
    if (ar == null) return;
    GetSlowStringDelegate d = ar.AsyncState as GetSlowStringDelegate;
    if (d == null) throw new Exception("Invalue object type");
    string result = d.EndInvoke(ar);
    this.Invoke(new Action(() => UpdateTextResult(result)));
}

调用委托实例的EndInvoke方法并传入IAsyncResult类型的对象用以获取GetSlowString的返回结果。

回调方法是委托线程调用的，因此它不能直接访问UI，所以我们使用窗体的Invoke方法在主线程中显示结果。如果委托方法抛出异常，将会在EndInvoke时抛出。

（二）使用Task类型

可以看到使用传统的办法编写异步调用很麻烦，特别是如果这种调用很多，那么我们的程序就会变成很复杂，逻辑很乱。

.NET 4.5提供的新的异步变成模式就很好地解决了这个问题（其实本质上应该是.NET自动实现了很多操作），使编写异步代码和同步调用一样逻辑清晰。

首先来看看微软的例子：

复制代码 代码如下:

private async Task SumPageSizesAsync()
{
    // To use the HttpClient type in desktop apps, you must include a using directive and add a
    // reference for the System.Net.Http namespace.
    HttpClient client = new HttpClient();

    // Equivalently, now that you see how it works, you can write the same thing in a single line.
    byte[] urlContents = await client.GetByteArrayAsync(url);
    // . . .
}

可以看出，使用await关键字后，.NET会自动把返回结果包装在一个Task类型的对象中。对于这个示例，方法是没有返回结果的。而对有返回结果的方法，就要使用Task<T>了：

复制代码 代码如下:

public async Task<string> WaitAsynchronouslyAsync()
{
    await Task.Delay(10000);
    return "Finished";
}

总而言之，使用await表达式时，控制会返回到调用此方法的线程中；在await等待的方法执行完毕后，控制会自动返回到下面的语句中。发生异常时，异常会在await表达式中抛出。

对于我们这个例子，我们编写的代码如下：

复制代码 代码如下:

private async void button1_Click(object sender, EventArgs e)
{
    textBox1.Text = "Requesting string, please wait...";

    WasteTimeObject ad = new WasteTimeObject();

    string result = await Task.Run(() => ad.GetSlowString(1, 10));

    //Update UI to display the result
    textBox1.Text = result;
}

我们使用Task类新建一个工作线程并执行。当然我们也可以像M$给的例子那样改造一下GetSlowString，这样就不需要加上Task.Run了。（基本上，这种方法都会以Async后缀结尾。）

如何？原来的：创建异步委托→回调一气呵成。另外还有一点，await下面的语句是由主线程调用的，不是由新的线程调用，所以我们可以直接访问UI。

（三）取消执行和显示进度

最后一个要记录的，就是如何给异步调用添加进度条，并能让用户取消操作。界面就是下面这样：

使用最终完成的代码来说明吧。首先改造GetSlowString方法，使之支持取消和汇报进度：

复制代码 代码如下:

public string GetSlowString(int begin, int length, IProgress<int> progress, CancellationToken cancel)
{
    StringBuilder sb = new StringBuilder();

    for (int i = begin; i < begin + length; i++)
    {
        sb.Append(WasteTime(i) + " ");

        cancel.ThrowIfCancellationRequested();

        if (progress != null)
            progress.Report((int)((double)(i - begin + 1) * 100 / length));
    }

    return sb.ToString();
}

IProgress<T>类型的对象有一个Report方法，执行这个方法实际上会调用自定义的更新进度的方法，这个方法（使用委托或匿名方法皆可）是在生成Progress<T>对象的时候指定的：

复制代码 代码如下:

IProgress<int> progress = new Progress<int>((progressValue) => { progressBar1.Value = progressValue; });

神奇的是，这个方法是由主线程调用的，如果不是这样，它就不能更新我们界面上的控件。所以说微软提供的新机制帮我们简化了很多工作。

CancellationToken用于指定该方法“绑定”的取消上下文，如果这个对象执行过Cancel方法（用户点击了Cancel按钮），那么访问ThrowIfCancellationRequested时就会抛出OperationCanceledException类型的异常。这种机制的灵活性在于中止执行的位置是可以自行确定的，不会出现取消时自己都不知道执行到哪行代码的情况。

总而言之，单击request按钮的代码我们修改如下：

复制代码 代码如下:

private async void button1_Click(object sender, EventArgs e)
{

    cancelSource = new CancellationTokenSource();
    IProgress<int> progress = new Progress<int>((progressValue) => { progressBar1.Value = progressValue; });

    textBox1.Text = "Requesting string, please wait...";
    button1.Enabled = false; button2.Enabled = true;

    WasteTimeObject ad = new WasteTimeObject();

    try
    {
        string result = await Task.Run(() => ad.GetSlowString(1, 10, progress, cancelSource.Token),
            cancelSource.Token);
        //Update UI to display the result
        textBox1.Text = result;
        button2.Enabled = false;  //Disable cancel button
    }
    catch (OperationCanceledException)
    {
        textBox1.Text = "You canceled the operation.";
    }

}

取消按钮的代码就很简单了：

复制代码 代码如下:

private void button2_Click(object sender, EventArgs e)
{
    if (cancelSource != null) cancelSource.Cancel();
    button2.Enabled = false;
}

至此，Task机制的初步体验就到此完成。以后有机会在研究下更高阶的内容吧。

[!--infotagslink--]

相关文章

  • ASP.NET购物车实现过程详解

    这篇文章主要为大家详细介绍了ASP.NET购物车的实现过程，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下...2021-09-22

  • .NET Core下使用Kafka的方法步骤

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

  • 在ASP.NET 2.0中操作数据之七十二：调试存储过程

    在开发过程中，使用Visual Studio的断点调试功能可以很方便帮我们调试发现程序存在的错误，同样Visual Studio也支持对SQL Server里面的存储过程进行调试，下面就让我们看看具体的调试方法。...2021-09-22

  • Win10 IIS 安装.net 4.5的方法

    这篇文章主要介绍了Win10 IIS 安装及.net 4.5及Win10安装IIS并配置ASP.NET 4.0的方法,本文给大家介绍的非常详细，具有一定的参考借鉴价值，需要的朋友可以参考下...2021-09-22

  • 详解.NET Core 3.0 里新的JSON API

    这篇文章主要介绍了详解.NET Core 3.0 里新的JSON API，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧...2021-09-22

  • .net数据库操作框架SqlSugar的简单入门

    这篇文章主要介绍了.net数据库操作框架SqlSugar的简单入门，帮助大家更好的理解和学习使用.net技术，感兴趣的朋友可以了解下...2021-09-22

  • ASP.NET Core根据环境变量支持多个 appsettings.json配置文件

    这篇文章主要介绍了ASP.NET Core根据环境变量支持多个 appsettings.json配置文件，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧...2021-09-22

  • 记一次EFCore类型转换错误及解决方案

    这篇文章主要介绍了记一次EFCore类型转换错误及解决方案，帮助大家更好的理解和学习使用asp.net core，感兴趣的朋友可以了解下...2021-09-22

  • 深入分析C# Task

    这篇文章主要介绍了C# Task的相关资料，文中讲解非常细致，代码帮助大家更好的理解和学习C# Task的相关知识，感兴趣的朋友可以了解下...2020-11-03

  • .NET C#利用ZXing生成、识别二维码/条形码

    ZXing是一个开放源码的，用Java实现的多种格式的1D/2D条码图像处理库，它包含了联系到其他语言的端口。这篇文章主要给大家介绍了.NET C#利用ZXing生成、识别二维码/条形码的方法，文中给出了详细的示例代码，有需要的朋友们可以参考借鉴。...2020-06-25

  • 详解ASP.NET Core 中基于工厂的中间件激活的实现方法

    这篇文章主要介绍了ASP.NET Core 中基于工厂的中间件激活的实现方法，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-09-22

  • C#使用Ado.Net更新和添加数据到Excel表格的方法

    这篇文章主要介绍了C#使用Ado.Net更新和添加数据到Excel表格的方法,较为详细的分析了OLEDB的原理与使用技巧,可实现较为方便的操作Excel数据,需要的朋友可以参考下...2020-06-25

  • asp.net通过消息队列处理高并发请求(以抢小米手机为例)

    这篇文章主要介绍了asp.net通过消息队列处理高并发请求(以抢小米手机为例)，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧...2021-09-22

  • ASP.NET 2.0中的数据操作:使用两个DropDownList过滤的主/从报表

    在前面的指南中我们研究了如何显示一个简单的主/从报表, 该报表使用DropDownList和GridView控件, DropDownList填充类别,GridView显示选定类别的产品. 这类报表用于显示具有...2016-05-19

  • ASP.NET单选按钮控件RadioButton常用属性和方法介绍

    RadioButton又称单选按钮，其在工具箱中的图标为 ，单选按钮通常成组出现，用于提供两个或多个互斥选项，即在一组单选钮中只能选择一个...2021-09-22

  • 详解.NET Core 使用HttpClient SSL请求出错的解决办法

    这篇文章主要介绍了.NET Core 使用HttpClient SSL请求出错的解决办法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧...2021-09-22

  • Python调用.NET库的方法步骤

    这篇文章主要介绍了Python调用.NET库的方法步骤，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧...2020-05-09

  • ASP.NET中iframe框架点击左边页面链接 右边显示链接页面内容

    这篇文章主要介绍了ASP.NET中iframe框架点击左边页面链接,右边显示链接页面内容的实现代码，感兴趣的小伙伴们可以参考一下...2021-09-22

  • 创建一个完整的ASP.NET Web API项目

    ASP.NET Web API具有与ASP.NET MVC类似的编程方式，ASP.NET Web API不仅仅具有一个完全独立的消息处理管道，而且这个管道比为ASP.NET MVC设计的管道更为复杂，功能也更为强大。下面创建一个简单的Web API项目，需要的朋友可以参考下...2021-09-22

  • ASP.NET连接MySql数据库的2个方法及示例

    这篇文章主要介绍了ASP.NET连接MySql数据库的2个方法及示例,使用的是MySQL官方组件和ODBC.NET,需要的朋友可以参考下...2021-09-22