欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

C#用委托BeginInvoke做异步线程

程序员文章站 2023-11-29 15:08:46
一个应用场景,浏览器上传一个文件,此文件后台调用文件转换,需要耗费相当长的时间,这样,如果是一个线程同步式的做下去,那么用户在浏览器上感觉就是卡住了,卡卡卡卡,这里我们利用...

一个应用场景,浏览器上传一个文件,此文件后台调用文件转换,需要耗费相当长的时间,这样,如果是一个线程同步式的做下去,那么用户在浏览器上感觉就是卡住了,卡卡卡卡,这里我们利用委托的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);

总结

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