C#用委托BeginInvoke做异步线程

 更新时间:2019年01月22日 15:30:16   作者:chenqiangdage  
今天小编就为大家分享一篇关于C#用委托BeginInvoke做异步线程,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧

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

总结

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

相关文章

  • C#不改变图像长宽比例调整图像大小方式

    C#不改变图像长宽比例调整图像大小方式

    文章介绍了在UI显示图片时,当容器大小固定而图片尺寸大于容器时,可以通过编码计算长宽来重绘图像,以确保图像的长宽比例不变,C#代码示例展示了如何在Winform前端实现这一功能
    2025-01-01
  • C#: 引用变量与数值变量的区别

    C#: 引用变量与数值变量的区别

    在C#中主要存在两大类型的数据:引用类型(class)和值类型(struct)。本文探讨一下C#中引用变量和数值变量的区别。
    2013-03-03
  • C#多线程同步lock、Mutex的实现

    C#多线程同步lock、Mutex的实现

    本文主要介绍了C#多线程同步lock、Mutex的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2024-05-05
  • C#学习笔记整理_变量等基础语法(必看篇)

    C#学习笔记整理_变量等基础语法(必看篇)

    下面小编就为大家带来一篇C#学习笔记整理_变量等基础语法(必看篇)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2016-09-09
  • C#集合本质之队列的用法详解

    C#集合本质之队列的用法详解

    本文详细讲解了C#集合本质之队列的用法,文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-08-08
  • C#非递归先序遍历二叉树实例

    C#非递归先序遍历二叉树实例

    这篇文章主要介绍了C#非递归先序遍历二叉树的实现方法,具有一定参考借鉴价值,需要的朋友可以参考下
    2015-07-07
  • C# 实现Zookeeper分布式锁的参考示例

    C# 实现Zookeeper分布式锁的参考示例

    Zookeeper分布式锁的原理是巧妙的是使用了znode临时节点的特点和监听(watcher)机制,监听机制很简单,就是我们可以给znode添加一个监听器,当znode节点状态发生改变时(如:数据内容改变,节点被删除),会通知到监听器。本文讲解使用c#实现该功能
    2021-06-06
  • C#使用二维数组模拟斗地主

    C#使用二维数组模拟斗地主

    这篇文章主要介绍了C#使用二维数组模拟斗地主的方法,通过C#的二维数组简单实现扑克随机发牌的功能,具有一定参考借鉴价值,需要的朋友可以参考下
    2015-04-04
  • C#调用js库的方法小结

    C#调用js库的方法小结

    本文主要介绍了C#调用js库的方法小结,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-04-04
  • Unity实现移动端手势解锁功能

    Unity实现移动端手势解锁功能

    这篇文章主要为大家详细介绍了Unity实现移动端手势解锁功能,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2020-07-07

最新评论