一. 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,记录时为了更好的学习。