[C#] 将同步方法改写为异步方法
[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); 接下来,将介绍如何将这支函数改写为可用异步的方式调用 1. 改写为基于IAsyncResult的异步模型首先,我们必须要先建立一个与函数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 Func 之后我们可以仿照数据流读取的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 else int result = calculator.EndCalculate(asyncResult); ?2. 改写为Event Based的异步模型?Event Based的异步模型,在执行完毕之后会将主控权交还给程序, 不会阻塞目前的Thread,一直到执行完毕之后,才会触发注册的事件。 首先我们建立一个当执行完毕时会触发的事件,并且会传入具有计算结果的EventArgs public event EventHandler 再来我们建立一个供程序调用的方法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#] 将同步方法改写为异步方法 (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |