其实早在.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机制的初步体验就到此完成。以后有机会在研究下更高阶的内容吧。

最新文章

  1. nullcon HackIM 2016 -- Crypto Question 2
  2. 从零开始写一个武侠冒险游戏-8-用GPU提升性能(3)
  3. php 下载保存文件保存到本地的两种方法
  4. IIS_各种问题
  5. 初学MFC
  6. 基于CSS3图片可倾斜摆放的动画相册
  7. hdu 4523 威威猫系列故事——过生日 小模拟
  8. PHPExcel导出excel
  9. java学习之运算符
  10. Akka入门实例
  11. 响应式布局中的CSS相对量
  12. C语言结构体中字符数组的问题
  13. NodeJs之数据库异常处理
  14. php curl请求
  15. CentOS 添加新的硬盘之后不停机操作
  16. 【转】asp.net Core 系列【二】—— 使用 ASP.NET Core 和 VS2017 for Windows 创建 Web API
  17. 【读书笔记】iOS-UDID
  18. Echo团队Alpha冲刺随笔 - 第二天
  19. HTML XHTML HTNL5 简介
  20. Luogu2149 [SDOI2009]Elaxia的路线-最短路+拓扑排序

热门文章

  1. FW:程序在内存的划分（转）
  2. 如何用Python实现常见机器学习算法-3
  3. xcconfig
  4. java类加载器的一些测试
  5. Word直接发布新浪博客(以Word 2010为例)
  6. 布局分析002：入门级的CSS导航弹出菜单
  7. 《全民无双》锁链刀光程序生成算法，即U3D——刀光轨迹插件的改进
  8. 词频统计-part2
  9. Tempdb--TempDB Basic
  10. 搭建自己的 Docker 私有仓库服务