首页 > 代码库 > .Net 异步调用

.Net 异步调用

一.  FrameWork 4.0之前的线程世界    

    在.NET FrameWork 4.0之前,如果我们使用线程。一般有以下几种方式:

  • 使用System.Threading.Thread 类,调用实例方法Start()开启一个新线程,调用Abort()方法来提前终止线程。
  • 使用System.Threading.ThreadPool类,调用静态方法QueueUserWorkItem(),将方法放入线程池队列,线程池来控制调用。
  • 使用BeginInvoke,EndInvoke,BeginRead,EnRead,BeginWrite,EndWrite等一系列的异步方法。
  • 使用System.ComponentModel.BackgroundWorker控件,调用实例方法RunWorkerAsync(),开启一个新线程。 

二.  .Net 传统异步编程概述 

  • 异步编程模型 (APM),在该模型中异步操作由一对 Begin/End 方法(如 FileStream.BeginRead 和 Stream.EndRead)表示。
  • 基于事件的异步模式 (EAP),在该模式中异步操作由名为“操作名称Async”和“操作名称Completed”的方法/事件对(例如 WebClient.DownloadStringAsync 和 WebClient.DownloadStringCompleted)表示。 (EAP 是在 .NET Framework 2.0 版中引入的,在silverlight或者wpf变成中经常用到)。

三.  Task 的优点以及功能   

  • 在任务启动后,可以随时以任务延续的形式注册回调。
  • 通过使用 ContinueWhenAll 和 ContinueWhenAny 方法或者 WaitAll 方法或 WaitAny 方法,协调多个为了响应 Begin_ 方法而执行的操作。
  • 在同一 Task 对象中封装异步 I/O 绑定和计算绑定操作。
  • 监视 Task 对象的状态。
  • 使用 TaskCompletionSource 将操作的状态封送到 Task 对象。

四.  TASK的用法

     请参考这篇文章

五.  使用 Task 封装常见的异步编程模式

  • 使用Task封装APM异步编程模式。C#5.0中提供的async和await使异步编程更简单。await在msdn的解释是“运算符应用于一个异步方法的任务挂起方法的执行,直到等待任务完成。 任务表示正在进行的工作。”它返回的结果是Task和Task<TResult>.下面我们就用一个demo具体解析:

    

private async void Init(){      //部分代码省略    var orgs = await _serviceClient.GetAllOrganizationTaskAsync();    }//通过WCF调用,采取分布类,名称一样。public partial class ServiceClient{ public Task<ObservableCollection<Organization>>   GetAllOrganizationTaskAsync()         {            //Task 封装APM             return Task<ObservableCollection<Organization>>.Factory.FromAsync(this.Channel.BeginGetAllOrganization,                                                      this.Channel.EndGetAllOrganization, null);         }}
  • 使用 Task 对象封装 EPM 异步模式 。 这种模式从 .Net 2.0 开始出现, 同时在 Silverlight 中大量出现, 这种异步模式以 “操作名称Async” 函数和 “操作名称Completed” 事件成对出现为特征。常见的操作有使用lamda表达式;或者使用+=“操作名称Completed”(tip:如果使用lamda表达式,无法回收资源,如果同时调用多个,数据会乱套,建议如果非要用,最好用+=“操作名称Completed”,在操作名称Completed事件中再-=“操作名称Completed”)。
    关键字:TaskCompletionSource,简单理解委托给task属性,利用task来操作。

 

var source = new TaskCompletionSource<string>();var webClient = new WebClient();webClient.DownloadStringCompleted += (sender, args) => {   if (args.Cancelled) {      source.SetCanceled();      return;   }   if (args.Error != null) {      source.SetException(args.Error);      return;   }   source.SetResult(args.Result);};webClient.DownloadStringAsync(new Uri(UrlToTest, UriKind.Absolute), null);source.Task.Wait();var result = source.Task.Result;

 

此博客来自于http://www.cnblogs.com/luqixinhe/archive/2013/07/18/3197645.html,记录时为了更好的学习。