Silverlight中對多個異步任務的調用

作者：陳希章 2011-08-30 10:20:41

Silverlight中對多個異步任務的調用本身比較麻煩，其思維比較呆板。本文將展示作者是如何去實現這個調用的。

　　這是一個常見的問題，由于Silverlight只支持異步調用后臺的服務，而如果有多個任務的話，可能就很麻煩，往往就是要在一個異步任務結束事件中去調用另外一個任務，以此類推。典型的問題就是，代碼很復雜，而且幾乎很難維護。看看下面的代碼吧

　　//傳統的多個異步任務的調用方法，必須是一層一層嵌套的方式  
　　var proxy = newServiceReference1.WebService1SoapClient();  
　　proxy.Endpoint.Address = newSystem.ServiceModel.EndpointAddress(  
　　newUri(App.Current.Host.Source, "../WebService1.asmx"));  
　　proxy.HelloWorldCompleted += (o, a) =>  
　　{  
　　proxy.GetEmployeeCompleted += (o1, a1) =>  
　　{  
　　proxy.GetCustomersCompleted += (o2, a1) =>  
　　{  
　　};  
　　proxy.GetCustomersAsync();  
　　};  
　　proxy.GetEmployeeAsync();  
　　};  
　　proxy.HelloWorldAsync();

　　為了解決這個問題，我自己也想過一些辦法，同時參考了張志敏的如下文章

　　http://www.cnblogs.com/beginor/archive/2010/12/24/1915910.html

　　這篇文章提供了一個不錯的思路。這篇文章的評論中，有朋友也提到了Reactive Framework，我看了看，還沒有找到很好的應用方法。這個Framework是一個很強大的東西，但在本文討論的場景中具體該如何應用，如果有這方面研究的朋友，請不吝賜教

　　在這篇文章提供的簡單模型基礎上，我做了一些修改，并且也增加了一些更加實用的特性。共享出來給大家參考

　　添加和改進的功能主要是：

　　1.使用更加便捷（原先是用IEnumerator去構造Runner，現在提供了更多的支持，可以是一個Array,也可以是一個List等等，因為我們很多時候任務是動態構造出來的）

　　2.提供了任務結果反饋（ActionResult)的功能

　　3.提供了任務之間約束的功能,在每個任務里面都可以得到前置任務的信息

　　如何使用？

　　第一步：添加Nuget Package，關于什么是Nuget，請參考 http://www.cnblogs.com/dudu/archive/2011/07/15/nuget.html

第二步，參考如下的范例代碼

　　運行效果

可以直接復制這個代碼進行使用或者修改

　　usingSystem;  
　　usingSystem.Collections.Generic;  
　　/*  
　　* 這個設計針對在Silverlight中經常需要對多個遠程服務進行調用，而且我們可能需要讓這些任務之間有固定的順序，同時還希望能夠在任務之間傳遞任務狀態。  
　　* 作者：陳希章  
　　* 時間：2011年8月30日  
　　* 反饋：ares@xizhang.com  
　　*/ 
　　#regionSample Code  
　　////第一個任務  
　　//var task = new AsyncAction();  
　　//task.SetAction(() =>  
　　//{  
　　// var proxy = new ServiceReference1.WebService1SoapClient();  
　　// proxy.Endpoint.Address = new System.ServiceModel.EndpointAddress(  
　　// new Uri(App.Current.Host.Source, "../WebService1.asmx"));  
　　// proxy.HelloWorldCompleted += (o, a) =>  
　　// {  
　　// task.ActionResult.TaskName = "Hello,world";  
　　// task.ActionResult.Message = "Test test";  
　　// task.ActionResult.Result = a.Result;  
　　// task.ActionResult.Status = ActionStatus.Success;  
　　// task.OnCompleted();  
　　// };  
　　// proxy.HelloWorldAsync();  
　　//}, true);  
　　////第二個任務  
　　//var task2 = new AsyncAction();  
　　//task2.SetAction(() =>  
　　//{  
　　// var proxy = new ServiceReference1.WebService1SoapClient();  
　　// proxy.Endpoint.Address = new System.ServiceModel.EndpointAddress(  
　　// new Uri(App.Current.Host.Source, "../WebService1.asmx"));  
　　// proxy.HelloWorldCompleted += (o, a) =>  
　　// {  
　　// task2.ActionResult.TaskName = "Hello,world";  
　　// task2.ActionResult.Message = "Test test";  
　　// task2.ActionResult.Result = a.Result;  
　　// task2.ActionResult.Status = ActionStatus.Success;  
　　// task2.OnCompleted();  
　　// };  
　　// proxy.HelloWorldAsync();  
　　//}, true);  
　　////構造Runner  
　　//var runner = new AsyncActionRunner(new[] { task, task2 });  
　　////注冊完成事件  
　　//runner.Completed += (o, a) =>  
　　//{  
　　// //將界面設置為空閑  
　　// busyIndicator.IsBusy = false;  
　　// //顯示所有任務的執行結果  
　　// dgResult.ItemsSource = runner.TaskResults;  
　　//};  
　　////將界面設置為忙碌  
　　//busyIndicator.IsBusy = true;  
　　////執行  
　　//runner.Execute();  
　　#endregion  
　　namespaceSystem  
　　{  
　　/// <summary>  
　　/// 這個枚舉記錄了任務的狀態，默認為Ready  
　　/// </summary>  
　publicenumActionStatus  
　{  
　　Ready,//準備好，如果最后檢查仍然為這個狀態，則通常表示該任務被跳過了  
　　Success,//成功  
　　Failure,//失敗  
　　Completed//完成  
　　}  
　　/// <summary>  
　　/// 這個記錄了任務的結果  
　　/// </summary>  
　　publicclassActionResult  
{  
　publicActionResult()  
　　{  
　　Status = ActionStatus.Ready;//默認為ready  
　　StartTime = DateTime.Now;  
　}  
/// <summary>  
　　/// 任務名稱  
　　/// </summary>  
　　publicstringTaskName { get; set; }  
　　/// <summary>  
　　/// 狀態  
　　/// </summary>  
　publicActionStatus Status { get; set; }  
　　/// <summary>  
　　/// 消息  
　　/// </summary>  
　　publicstringMessage { get; set; }  
　　/// <summary>  
　　/// 任務結果  
　　/// </summary>  
　　publicobjectResult { get; set; }  
　　/// <summary>  
　　/// 開始時間  
　　/// </summary>  
　　publicDateTime StartTime { get; set; }  
　　/// <summary>  
　　/// 結束時間  
　　/// </summary>  
　　publicDateTime EndTime { get; set; }  
　　}  
　　/// <summary>  
　　/// 異步任務的接口  
　　/// </summary>  
　publicinterfaceIAsyncAction  
　　{  
　　voidExecute();  
　　eventEventHandler Completed;  
　　ActionResult PreActionResult { get; set; }  
　　ActionResult ActionResult { get; set; }  
　　}  
　　/// <summary>  
　/// 異步任務的實現類型  
　　/// </summary>  
　　publicclassAsyncAction : IAsyncAction  
　　{  
　　publicAsyncAction()  
　{  
　　ActionResult = newActionResult();  
　　}  
　　privateboolAutoComplete = false;  
　　privateAction Action { get; set; }  
　　/// <summary>  
　/// 設置要執行的操作  
　　/// </summary>  
　　/// <param name="action">操作</param>  
　　/// <param name="autoComplete">是否自動完成</param>  
　　publicvoidSetAction(Action action, boolautoComplete)  
　　{  
　Action = action;  
　　AutoComplete = autoComplete;  
　　}  
　　publicvirtualvoidExecute()  
　　{  
　　if(Action != null)  
　　{  
　　ActionResult.StartTime = DateTime.Now;  
　　Action();  
　　if(!AutoComplete)  
　　OnCompleted();  
　　}  
　　}  
　　publiceventEventHandler Completed;  
　　publicvoidOnCompleted()  
　　{  
　　var completed = this.Completed;  
　　if(completed != null)  
　{  
　completed(this, EventArgs.Empty);  
　　}  
　　}  
　　/// <summary>  
　　/// 前置任務的結果，添加這個功能目的是，可能多個任務之間互相有所依賴，例如某個任務要根據前面任務的情況決定是否執行  
　　/// </summary>  
　　publicActionResult PreActionResult { get; set; }  
　　/// <summary>  
　　/// 當前任務的結果  
　/// </summary>  
　　publicActionResult ActionResult { get; set; }  
　　}  
　　/// <summary>  
　　/// 任務運行器  
　　/// </summary>  
　　publicclassAsyncActionRunner  
　　{  
　　publicAsyncActionRunner()  
　　{  
　　TaskResults = newList<ActionResult>();  
　　}  
　　privatereadonlyIEnumerator<IAsyncAction> _enumerator;  
　　publicAsyncActionRunner(IEnumerator<IAsyncAction> enumerator)  
　　: this()  
　　{  
　　this._enumerator = enumerator;  
　　}  
　　publicAsyncActionRunner(IEnumerable<IAsyncAction> tasks)  
　　: this()  
　　{  
　　_enumerator = tasks.GetEnumerator();  
　　}  
　　/// <summary>  
　　/// 完成事件及處理方法  
　　/// </summary>  
　　publiceventEventHandler Completed;  
　　/// <summary>  
　　/// 保存所有任務的執行結果  
　　/// </summary>  
　　publicList<ActionResult> TaskResults { get; privateset; }  
　　/// <summary>  
　　/// 臨時保存的當前任務的執行結果  
　　/// </summary>  
　　privateActionResult tmp = null;  
　　/// <summary>  
　　/// 執行所有任務  
　　/// </summary>  
　　publicvoidExecute()  
　　{  
　　if(this._enumerator.MoveNext())  
　　{  
　　this._enumerator.Current.Completed += (sender, args) =>  
　　{  
　　tmp = ((IAsyncAction)sender).ActionResult;  
　　tmp.EndTime = DateTime.Now;  
　　TaskResults.Add(tmp);  
　　this.Execute();  
　　};  
　　this._enumerator.Current.PreActionResult = tmp;  
　　this._enumerator.Current.Execute();  
　　}  
　　else 
　　{  
　　var completed = this.Completed;  
　if(completed != null)  
　　{  
　　completed(this, EventArgs.Empty);  
　　}  
　　}  
　　}  
　　}  
　　}

原文鏈接：http://www.cnblogs.com/chenxizhang/archive/2011/08/30/2159124.html

【編輯推薦】

Windows 8將.NET和Silverlight打入冷宮？
微軟Silverlight的崛起
Silverlight 5，你的名字是“Windows”
微軟發布Silverlight 5 beta 附下載
微軟Silverlight的崛起

責任編輯：彭凡來源：博客園

Silverlight

成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

Silverlight中對多個異步任務的調用