[C#] 将同步方法改写为异步方法
前言
当我们遇到所需要花费较长时间的程序时,
我们通常会透过异步的方式来调用它 (比如读取数据流的BeginRead,EndRead),
那如果本来是同步的方法,我们有没有办法可以改写它呢?
这篇的主题就是要来介绍如何将同步(sync)的程序改写为异步(async)的程序。
实际演练
在.Net Framework中,异步模型(APM)大致上可以区分为两类,
基于IAsyncResult的异步模型,以及Event Based的异步模型,
我们先来建立一个很简单的加法函数,并且为它加入Thread.Sleep来模拟花费大量的时间,
public class Calculator{ public int Calculate(int a,int b) { // 模拟花费大量时间运算 System.Threading.Thread.Sleep(10 * 1000); return a + b; }}
通常在程序中执行此函数时看起来会像这样,程序会卡在这边非常久
Calculator calculator = new Calculator();// 程序会停在这边很长的时间int result = calculator.Calculate(1,2);
接下来,将介绍如何将这支函数改写为可用异步的方式调用
首先,我们必须要先建立一个与函数input和Output相同的delegate,
因为在3.5之后的版本已经有内建Func,所以在今天的范例就直接使用Func来当作delegate,
//In 2.0,sample,not work//private delegate int CalculateDelegate(int a,int b);//CalculateDelegate m_calculateDelegate = new CalculateDelegate(Calculate);private Funcm_calculateDelegate; ,>
之后我们可以仿照数据流读取的BeginRead和EndRead一样,分别撰写Begincalculate和EndCalculate方法,
public IAsyncResult Begincalculate(int a,int b){ this.m_calculateDelegate = this.Calculate; return this.m_calculateDelegate.BeginInvoke(a,b,null,null);}public int EndCalculate(IAsyncResult asyncResult){ return this.m_calculateDelegate.EndInvoke(asyncResult);}
如此一来,我们就可以在程序中使用异步的方法调用Begincalculate和EndCalculate,
并且可以在程序计算完毕之前,继续做其他的事情,
Calculator calculator = new Calculator();IAsyncResult asyncResult = calculator.Begincalculate(1,2);// Do something elseint result = calculator.EndCalculate(asyncResult);?2. 改写为Event Based的异步模型?
Event Based的异步模型,在执行完毕之后会将主控权交还给程序,
不会阻塞目前的Thread,一直到执行完毕之后,才会触发注册的事件。
首先我们建立一个当执行完毕时会触发的事件,并且会传入具有计算结果的EventArgs
public event EventHandlerCalculateFinished; public class CalculateFinishedEventArgs : EventArgs { public int Result { get; private set; } public CalculateFinishedEventArgs(int result) { this.Result = result; } }
再来我们建立一个供程序调用的方法CalculateAsync,在执行之后并不会阻塞Thread,
并且会在执行完毕之后,触发CalculateFinished事件,
public voID CalculateAsync(int a,int b){ this.m_calculateDelegate = Calculate; AsyncCallback callback = new AsyncCallback(OncalculateFinished); this.m_calculateDelegate.BeginInvoke(a,callback,m_calculateDelegate);}private voID OncalculateFinished(IAsyncResult asyncResult){ Func calculateDelegate = (Func)asyncResult.AsyncState; int result = calculateDelegate.EndInvoke(asyncResult); EventHandler temp = CalculateFinished; if (temp != null) { temp(this,new CalculateFinishedEventArgs(result)); }},>,>
执行程序就可改写如下
Calculator calculator = new Calculator(); calculator.CalculateFinished += (o,args) => MessageBox.Show(string.Format("Result is {0}",args.Result));calculator.CalculateAsync(1,2);// Do other works...
结语
为了有效的利用系统资源,并行作业,以及提供使用者良好的使用者体验,
在撰写程序时使用异步的方法调用是不可或缺的,
但在撰写异步程序的同时,却往往会造成程序较为零碎,
而比较不容易阅读和维护的困扰,在下次的文章之中,
会来介绍如何使用Iterator来改善这种情况,
当然也可以利用之前介绍的异步调用方法并跳出处理中窗口,
透过BackgrounDWorker或是Thread的方式来处理,
也欢迎大家一起多多讨论和指教啰 ^_^
参考数据:
1. http://msdn.microsoft.com/zh-tw/library/2e08f6yc(v=VS.100).aspx 以异步的方式调用同步方法
2. http://msdn.microsoft.com/zh-tw/magazine/cc163467.aspx 实践 CLR 异步程序撰写模型
原文:大专栏 [C#] 将同步方法改写为异步方法
总结以上是内存溢出为你收集整理的[C#] 将同步方法改写为异步方法全部内容,希望文章能够帮你解决[C#] 将同步方法改写为异步方法所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)