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);

来源：https://blog.csdn.net/chenqiangdage/article/details/49910483