[C#] 将同步方法改写为异步方法

[C#] 将同步方法改写为异步方法,第1张

概述[C#] 将同步方法改写为异步方法 前言 当我们遇到所需要花费较长时间的程序时, 我们通常会透过异步的方式来调用它 (比如读取数据流的BeginRead, EndRead), 那如果本来是同步的方法,我们有没有办法可以改写它呢? 这篇的主题就是要来介绍如何将同步(sync)的程序改写为异步(async)的程序。 实际演练 在.Net Framework中,异步模型(APM)大致上可以区分为两类,

[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       m_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 EventHandler       CalculateFinished; 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#] 将同步方法改写为异步方法所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。

欢迎分享,转载请注明来源:内存溢出

原文地址: https://outofmemory.cn/langs/1214679.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-06-05
下一篇 2022-06-05

发表评论

登录后才能评论

评论列表(0条)

保存