C#用委托BeginInvoke做异步线程
一个应用场景,浏览器上传一个文件,此文件后台调用文件转换,需要耗费相当长的时间,这样,如果是一个线程同步式的做下去,那么用户在浏览器上感觉就是卡住了,卡卡卡卡,这里我们利用委托的BeginInvoke和EndInvoke方法操作线程,BeginInvoke方法可以使用线程异步地执行委托所指向的方法。然后通过EndInvoke方法获得方法的返回值(EndInvoke方法的返回值就是被调用方法的返回值),或是确定方法已经被成功调用,说白了就是相当于开个多线程,你用户文件保存了之后,响应返回,这个BeginInvoke异步去执行委托方法,完了之后呢,再执行你的异步回调函数;
大概步骤
1:先把你要异步执行的方法抽离出来;
2:定义一个该异步方法的委托;
3:在调用地方实例化这个委托;
4:调用此委托实例的BeginInvoke方法,在此方法里,前面填委托的参数,接着是委托方法结束后的回调函数;
5:写委托的回调函数,回调函数是固定的参数(IAsyncResultIR)在这个里面,可以获取用户定义的对象,它限定或包含关于异步操作的信息(AsyncState)然后调用EndInvoke,获取到委托方法结束的返回值。
6:调用自定义的回调函数;
还是看代码吧:
publicclassanysFileChange
{
///
///文件change后,其对应的业务逻辑所需要做的变动锁调用的委托
///转换完之后会调用所执行的函数,用户需要干什么,这个函数则交由用户自己的逻辑完成
///
publicstaticanysChangingHandlerCallBack_handler=null;
///
///转换文件
///
///文件路径
///
publicstaticvoidChangingFile(stringfilepath,stringattachId)
{
//开启异步转换
DEGAsyncChangingFileacf=newDEGAsyncChangingFile(anysFileChange.AsyncChangeFileToswf);
acf.BeginInvoke(filepath,attachId,anysFileChange.CallBackAsync,acf);
}
///
///异步函数执行完后的的回调函数
///
///异步结果
///
privatestaticvoidCallBackAsync(IAsyncResultIR)
{
DEGAsyncChangingFileacf=(DEGAsyncChangingFile)IR.AsyncState;
ResultObjresult=(ResultObj)acf.EndInvoke(IR);
//如果调用文件转换结束方法有定义转换结束需要做的委托那么执行用户定义的委托函数
if(_handler!=null&&result!=null)
{
///成功才执行客户自定义的回调函数
if(result.changestaus==EnumChangeStatus.SUCCESS)
{
_handler(result.filepath,result.attachId);
}
}
}
///
///转换文件
///
///文件路径
///HSUFResultObj返回结果对象
privatestaticResultObjAsyncChangeFileToswf(stringfilepath,stringattachId)
{
ResultObjres=newResultObj();
//转换动作
ConvertFilecf=newConvertFile();
//cf这个类提供了一个写日志的事件注册一个写日志事件
cf.ConvertLog+=newConvertFile.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;
}
returnres;
}
///
///供注册的日志事件
///
///
privatestaticvoidSyslog(stringmessages)
{
stringseparateLine="\r\n============================================================================================\r\n";
stringlog=string.Format(@"{0}{1}{2}{0}",separateLine,DateTime.Now.ToString(),messages);
//如果上传课程文件夹不存在,则创建
if(!Directory.Exists(ConverConst.toolpath+"Log\\"))
Directory.CreateDirectory(ConverConst.toolpath+"Log\\");
StreamWritersw=newStreamWriter(ConverConst.toolpath+"Log\\"+DateTime.Now.ToString("yyyy-MM-dd")+".txt",true);
sw.WriteLine(log);
sw.Close();
}
///
///文件转换委托
///
///文件路径
///
privatedelegateobjectDEGAsyncChangingFile(stringfilepath,stringattachId);
}
///
///结果集对象
///
publicclassResultObj
{
///
///文件路径
///
publicstringfilepath;
///
///id
///
publicstringattachId;
///
///转换结果消息
///
publicstringchangeMessage;
///
///转换状态
///
publicEnumChangeStatuschangestaus;
}
///
///文件转换后,业务逻辑所需要调用的委托
///
///文件路径
publicdelegatevoidanysChangingHandlerCallBack(stringfilepath,stringattchid);
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对毛票票的支持。如果你想了解更多相关内容请查看下面相关链接