当前位置:  编程技术>.net/c#/asp.net

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

    来源: 互联网  发布时间:2014-10-30

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

其实早在.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了:

代码如下:

public async Task 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 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类型的对象有一个Report方法,执行这个方法实际上会调用自定义的更新进度的方法,这个方法(使用委托或匿名方法皆可)是在生成Progress对象的时候指定的:

代码如下:

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

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

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

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

代码如下:

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

    cancelSource = new CancellationTokenSource();
    IProgress progress = new Progress((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机制的初步体验就到此完成。以后有机会在研究下更高阶的内容吧。


    
 
 

您可能感兴趣的文章:

  • .net4.5使用async和await异步编程实例
  • .net的socket异步通讯示例分享
  • asp.net 使用js分页实现异步加载数据
  • 请问如何在vc++.net中调用.o文件,或者.so文件
  • 内核源文件/net/socket.c中调用其他模块的函数,该如何实现
  • Asp.Net其他页面如何调用Web用户控件写的分页
  • Asp.net后台调用js脚本的方法
  • .net后台代码调用前台JS的两种方式
  • 200分送上,欢迎讨论用java调用vs.net所创建的web服务!
  • .Net 调用存储过程取到return的返回值
  • asp.net调用飞信免费发短信(测试有效)
  • asp.net 操作cookie实例详解 iis7站长之家
  • .net中前台javascript与后台c#函数相互调用问题
  • asp.net调用存储过程详解
  • jquery $.ajax()调用asp.net后台的方法
  • jquery.Ajax()方法调用Asp.Net后台的方法解析
  •  
    本站(WWW.)旨在分享和传播互联网科技相关的资讯和技术,将尽最大努力为读者提供更好的信息聚合和浏览方式。
    本站(WWW.)站内文章除注明原创外,均为转载、整理或搜集自网络。欢迎任何形式的转载,转载请注明出处。












  • 相关文章推荐
  • .NET下 c#通过COM组件操作并导出Excel实例代码
  • asp.net输出重写压缩页面文件的实例
  • vb.net实例代码 连接访问数据库文件(mdb)
  • c#(asp.net)连接excel的实例代码
  • DataGrid的Pagable(VB.NET)实例代码
  • vb.net实例代码 在访问表中遍历记录
  • 关于C#.net winform程序验证moss的集成身份认证实例
  • asp.net 伪静态简单实例
  • .net实现序列化与反序列化实例解析
  • vb.net DropDownList控件实例代码 在DropDownList控件中显示访问数据
  • C#实现只运行单个实例应用程序的方法(使用VB.Net的IsSingleInstance)
  • asp.net取得所有颜色值实例
  • asp.net操作cookie实例代码
  • asp.net 动态添加多个用户控件(实例代码)
  • asp.net实例 定义和使用asp:AccessDataSource
  • asp.net 动态创建控件的演示实例
  • asp.net 邮件发送类的简单实例
  • asp.net实例代码 在DataGrid控件中显示数据
  • ASP.net WebAPI 上传图片实例
  • asp.net 操作cookie实例详解
  • asp.net读取与删除磁盘文件的实例代码
  • java命名空间javax.net类socketfactory的类成员方法: createsocket定义及介绍
  • .NET版的ExtJS库 Ext.Net
  • java命名空间java.net类datagramsocket的类成员方法: disconnect定义及介绍
  • node.js的.net扩展 node.net
  • java命名空间java.net类datagramsocket的类成员方法: close定义及介绍
  • 为什么输http://www.china-java.net,会自动改为http://www.china-java.net:8081?
  • java命名空间java.net接口cookiestore的类成员方法: get定义及介绍
  • 各位之不知道net-snmp是否收费?我的产品中用到了net-snmp lib是否需要向什么单位或者组织付费?
  • java命名空间java.net类socket的类成员方法: isbound定义及介绍
  • 【人才】有没有人会用VC6.0/VS2003.NET/VS2005.NET写WINDOWS下的驱动程序呀。


  • 站内导航:


    特别声明:169IT网站部分信息来自互联网,如果侵犯您的权利,请及时告知,本站将立即删除!

    ©2012-2021,,E-mail:www_#163.com(请将#改为@)

    浙ICP备11055608号-3