C#中怎么利用委托BeginInvoke实现异步线程

C#中怎么利用委托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);

看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注亿速云行业资讯频道，感谢您对亿速云的支持。