重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
C#中怎么利用委托BeginInvoke实现异步线程,很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。
专注于为中小企业提供成都做网站、成都网站设计服务,电脑端+手机端+微信端的三站合一,更高效的管理,为中小企业怀柔免费做网站提供优质的服务。我们立足成都,凝聚了一批互联网行业人才,有力地推动了超过千家企业的稳健成长,帮助中小企业通过网站建设实现规模扩充和转变。
大概步骤
1:先把你要异步执行的方法抽离出来;
2:定义一个该异步方法的委托;
3:在调用地方实例化这个委托;
4:调用此委托实例的BeginInvoke方法,在此方法里,前面填委托的参数,接着是委托方法结束后的回调函数;
5:写委托的回调函数,回调函数是固定的参数(IAsyncResultIR)在这个里面,可以获取用户定义的对象,它限定或包含关于异步操作的信息(AsyncState)然后调用EndInvoke,获取到委托方法结束的返回值。
6:调用自定义的回调函数;
还是看代码吧:
public class anysFileChange { ////// 文件change后,其对应的业务逻辑所需要做的变动锁调用的委托 /// 转换完之后 会调用所执行的函数,用户需要干什么,这个函数则交由用户自己的逻辑完成 /// public static anysChangingHandlerCallBack _handler = null; ////// 转换文件 /// /// 文件路径 ///public static void ChangingFile(string filepath, string attachId) { //开启异步转换 DEGAsyncChangingFile acf = new DEGAsyncChangingFile(anysFileChange.AsyncChangeFileToswf); acf.BeginInvoke(filepath, attachId, anysFileChange.CallBackAsync, acf); } /// /// 异步函数执行完后的的回调函数 /// /// 异步结果 ///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); } } } /// /// 转换文件 /// /// 文件路径 ///HSUFResultObj 返回结果对象 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; } ////// 供注册的日志事件 /// /// 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(); } ////// 文件转换委托 /// /// 文件路径 ///private delegate object DEGAsyncChangingFile(string filepath,string attachId); } /// /// 结果集对象 /// public class ResultObj { ////// 文件路径 /// public string filepath; ////// id /// public string attachId; ////// 转换结果消息 /// public string changeMessage; ////// 转换状态 /// public EnumChangeStatus changestaus; } ////// 文件转换后,业务逻辑所需要调用的委托 /// /// 文件路径 public delegate void anysChangingHandlerCallBack(string filepath,string attchid);
看完上述内容是否对您有帮助呢?如果还想对相关知识有进一步的了解或阅读更多相关文章,请关注创新互联行业资讯频道,感谢您对创新互联的支持。