C# 用委託BeginInvoke做非同步執行緒
阿新 • • 發佈：2019-02-13
一個應用場景，瀏覽器上傳一個檔案，此檔案後臺呼叫檔案轉換，需要耗費相當長的時間，這樣，如果是一個執行緒同步式的做下去，那麼使用者在瀏覽器上感覺就是卡住了，卡卡卡卡，這裡我們利用委託的BeginInvoke和EndInvoke方法操作執行緒，BeginInvoke方法可以使用執行緒非同步地執行委託所指向的方法。然後通過EndInvoke方法獲得方法的返回值（EndInvoke方法的返回值就是被呼叫方法的返回值），或是確定方法已經被成功呼叫，說白了就是相當於開個多執行緒，你使用者檔案儲存了之後，響應返回，這個BeginInvoke非同步去執行委託方法，完了之後呢，再執行你的非同步回撥函式；
大概步驟
1：先把你要非同步執行的方法抽離出來；
2：定義一個該非同步方法的委託；
3：在呼叫地方例項化這個委託；
4：呼叫此委託例項的BeginInvoke方法，在此方法裡，前面填委託的引數，接著是委託方法結束後的回撥函式；
5：寫委託的回撥函式，回撥函式是固定的引數（
在這個裡面，可以獲取使用者定義的物件，它限定或包含關於非同步操作的資訊（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);