C#中怎么利用委托BeginInvoke實現(xiàn)異步線程

C#中怎么利用委托BeginInvoke實現(xiàn)異步線程，很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細講解，有這方面需求的人可以來學習下，希望你能有所收獲。

大概步驟

1：先把你要異步執(zhí)行的方法抽離出來；

2：定義一個該異步方法的委托；

3：在調(diào)用地方實例化這個委托；

4：調(diào)用此委托實例的BeginInvoke方法，在此方法里，前面填委托的參數(shù)，接著是委托方法結束后的回調(diào)函數(shù)；

5：寫委托的回調(diào)函數(shù)，回調(diào)函數(shù)是固定的參數(shù)（IAsyncResultIR）在這個里面，可以獲取用戶定義的對象，它限定或包含關于異步操作的信息（AsyncState）然后調(diào)用EndInvoke,獲取到委托方法結束的返回值。

6：調(diào)用自定義的回調(diào)函數(shù)；

還是看代碼吧：

  public class anysFileChange
  {
    /// <summary>
    /// 文件change后，其對應的業(yè)務邏輯所需要做的變動鎖調(diào)用的委托
    /// 轉(zhuǎn)換完之后 會調(diào)用所執(zhí)行的函數(shù)，用戶需要干什么，這個函數(shù)則交由用戶自己的邏輯完成
    /// </summary>
    public static anysChangingHandlerCallBack _handler = null;
    /// <summary>
    /// 轉(zhuǎn)換文件
    /// </summary>
    /// <param name="filepath">文件路徑</param> 
    /// <returns></returns>
    public static void ChangingFile(string filepath, string attachId)
    {
      //開啟異步轉(zhuǎn)換
      DEGAsyncChangingFile acf = new DEGAsyncChangingFile(anysFileChange.AsyncChangeFileToswf);
      acf.BeginInvoke(filepath, attachId, anysFileChange.CallBackAsync, acf);      
    }
    /// <summary>
    /// 異步函數(shù)執(zhí)行完后的的回調(diào)函數(shù)
    /// </summary>
    /// <param name="IR">異步結果 </param>
    /// <returns></returns>
    private static void CallBackAsync(IAsyncResult IR)
    {
      DEGAsyncChangingFile acf = (DEGAsyncChangingFile)IR.AsyncState;
      ResultObj result = (ResultObj)acf.EndInvoke(IR);
      //如果調(diào)用 文件轉(zhuǎn)換結束方法有定義 轉(zhuǎn)換結束需要做的委托那么執(zhí)行用戶定義的委托函數(shù)
      if (_handler != null && result != null)
      {
        ///成功才執(zhí)行客戶自定義的回調(diào)函數(shù)
        if (result.changestaus == EnumChangeStatus.SUCCESS)
        {
          _handler(result.filepath, result.attachId);
        }
      }
    }
    /// <summary>
    /// 轉(zhuǎn)換文件
    /// </summary>
    /// <param name="filepath">文件路徑</param> 
    /// <returns>HSUFResultObj 返回結果對象</returns>
    private static ResultObj AsyncChangeFileToswf(string filepath,string attachId)
    {
      ResultObj res = new ResultObj();
      //轉(zhuǎn)換動作
      ConvertFile cf = new ConvertFile();
      //cf這個類提供了一個寫日志的事件 注冊一個寫日志事件
      cf.ConvertLog += new ConvertFile.ConvertLogHandler(Syslog);
      //這里的cf這個類提供的方法，僅僅利用里面的轉(zhuǎn)換方法算了      
       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);
      // 如果上傳課程文件夾不存在，則創(chuàng)建
      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>
    /// 文件轉(zhuǎn)換委托
    /// </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>
    /// 轉(zhuǎn)換結果消息 
    /// </summary>
    public string changeMessage;
    /// <summary>
    /// 轉(zhuǎn)換狀態(tài)
    /// </summary>
    public EnumChangeStatus changestaus;
  }
  /// <summary>
  /// 文件轉(zhuǎn)換后，業(yè)務邏輯所需要調(diào)用的委托
  /// </summary>
  /// <param name="filepath">文件路徑</param> 
  public delegate void anysChangingHandlerCallBack(string filepath,string attchid);

看完上述內(nèi)容是否對您有幫助呢？如果還想對相關知識有進一步的了解或閱讀更多相關文章，請關注億速云行業(yè)資訊頻道，感謝您對億速云的支持。