首页 > 编程 > C# > 正文

C#用委托BeginInvoke做异步线程

2020-01-24 00:11:06
字体:
来源:转载
供稿:网友

一个应用场景,浏览器上传一个文件,此文件后台调用文件转换,需要耗费相当长的时间,这样,如果是一个线程同步式的做下去,那么用户在浏览器上感觉就是卡住了,卡卡卡卡,这里我们利用委托的BeginInvoke和EndInvoke方法操作线程,BeginInvoke方法可以使用线程异步地执行委托所指向的方法。然后通过EndInvoke方法获得方法的返回值(EndInvoke方法的返回值就是被调用方法的返回值),或是确定方法已经被成功调用,说白了就是相当于开个多线程,你用户文件保存了之后,响应返回,这个BeginInvoke异步去执行委托方法,完了之后呢,再执行你的异步回调函数;

大概步骤

1:先把你要异步执行的方法抽离出来;

2:定义一个该异步方法的委托;

3:在调用地方实例化这个委托;

4:调用此委托实例的BeginInvoke方法,在此方法里,前面填委托的参数,接着是委托方法结束后的回调函数;

5:写委托的回调函数,回调函数是固定的参数(IAsyncResultIR)在这个里面,可以获取用户定义的对象,它限定或包含关于异步操作的信息(AsyncState)然后调用EndInvoke,获取到委托方法结束的返回值。

6:调用自定义的回调函数;

还是看代码吧:

  public class anysFileChange  {    /// <summary>    /// 文件change后,其对应的业务逻辑所需要做的变动锁调用的委托    /// 转换完之后 会调用所执行的函数,用户需要干什么,这个函数则交由用户自己的逻辑完成    /// </summary>    public static anysChangingHandlerCallBack _handler = null;    /// <summary>    /// 转换文件    /// </summary>    /// <param name="filepath">文件路径</param>     /// <returns></returns>    public static void ChangingFile(string filepath, string attachId)    {      //开启异步转换      DEGAsyncChangingFile acf = new DEGAsyncChangingFile(anysFileChange.AsyncChangeFileToswf);      acf.BeginInvoke(filepath, attachId, anysFileChange.CallBackAsync, acf);          }    /// <summary>    /// 异步函数执行完后的的回调函数    /// </summary>    /// <param name="IR">异步结果 </param>    /// <returns></returns>    private static void CallBackAsync(IAsyncResult IR)    {      DEGAsyncChangingFile acf = (DEGAsyncChangingFile)IR.AsyncState;      ResultObj result = (ResultObj)acf.EndInvoke(IR);      //如果调用 文件转换结束方法有定义 转换结束需要做的委托那么执行用户定义的委托函数      if (_handler != null && result != null)      {        ///成功才执行客户自定义的回调函数        if (result.changestaus == EnumChangeStatus.SUCCESS)        {          _handler(result.filepath, result.attachId);        }      }    }    /// <summary>    /// 转换文件    /// </summary>    /// <param name="filepath">文件路径</param>     /// <returns>HSUFResultObj 返回结果对象</returns>    private static ResultObj AsyncChangeFileToswf(string filepath,string attachId)    {      ResultObj res = new ResultObj();      //转换动作      ConvertFile cf = new ConvertFile();      //cf这个类提供了一个写日志的事件 注册一个写日志事件      cf.ConvertLog += new ConvertFile.ConvertLogHandler(Syslog);      //这里的cf这个类提供的方法,仅仅利用里面的转换方法算了             cf.Convert(filepath);            if (cf.ChangeResult == EnumChangeStatus.SUCCESS)       {         res.attachId = attachId;                         res.filepath = filepath;         res.changestaus = cf.ChangeResult;       }       else       {         res.changeMessage = cf.convertMessage;         res.changestaus = cf.ChangeResult;       }      return res;    }    /// <summary>    /// 供注册的日志事件    /// </summary>    /// <param name="messages"></param>    private static void Syslog(string messages)    {      string separateLine = "/r/n============================================================================================/r/n";      string log = string.Format(@"{0} {1} {2} {0}", separateLine, DateTime.Now.ToString(), messages);      // 如果上传课程文件夹不存在,则创建      if (!Directory.Exists(ConverConst.toolpath + "Log//"))        Directory.CreateDirectory(ConverConst.toolpath + "Log//");      StreamWriter sw = new StreamWriter(ConverConst.toolpath+"Log//"+DateTime.Now.ToString("yyyy-MM-dd")+".txt", true);      sw.WriteLine(log);      sw.Close();    }    /// <summary>    /// 文件转换委托    /// </summary>    /// <param name="filepath">文件路径</param>     /// <returns> </returns>    private delegate object DEGAsyncChangingFile(string filepath,string attachId);  }  /// <summary>  /// 结果集对象  /// </summary>  public class ResultObj  {    /// <summary>    /// 文件路径    /// </summary>    public string filepath;    /// <summary>    /// id    /// </summary>    public string attachId;    /// <summary>    /// 转换结果消息     /// </summary>    public string changeMessage;    /// <summary>    /// 转换状态    /// </summary>    public EnumChangeStatus changestaus;  }  /// <summary>  /// 文件转换后,业务逻辑所需要调用的委托  /// </summary>  /// <param name="filepath">文件路径</param>   public delegate void anysChangingHandlerCallBack(string filepath,string attchid);

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对武林网的支持。如果你想了解更多相关内容请查看下面相关链接

发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表