定義一個異步線程類:
public class AsyEventClass { private static ILog logger = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); //異步線程,委托 public delegate string AsyncEventHandler(long num1, long num2); public string ToDealData(long num1, long num2) { logger.Error("異步處理數據開始:num1:" + mainDigitalId + ",num2:"); //處理數據或其他操作return "異步成功,num1:" + mainDigitalId + ",num2:" + bindDigitalId; } public void Callback(IAsyncResult result) { AsyncEventHandler handler = (AsyncEventHandler)((AsyncResult)result).AsyncDelegate; logger.Error(handler.EndInvoke(result)); } }
第一 同步調用
public class Program { static void Main() { Console.WriteLine("===== 同步調用,阻塞當前線程 ====="); AsyEventClass ac = new AsyEventClass(); AsyEventClass.AsyncEventHandler asy = new AsyEventClass.AsyncEventHandler(ac.ToDealData); string result = asy.Invoke(num1,num2); Console.WriteLine("此處會等上一步執行完再執行"); Console.WriteLine(result); } }
第二 異步調用
public class Program { static void Main() { Console.WriteLine("=====異步調用,不會阻塞 ,但EndInvoke會因等待結果而阻塞===="); AsyEventClass ac = new AsyEventClass(); AsyEventClass.AsyncEventHandler asy = new AsyEventClass.AsyncEventHandler(ac.ToDealData); IAsyncResult result = asy.BeginInvoke(num1,num2,null,null); Console.WriteLine("此處不受影響,繼續執行"); Console.WriteLine(asy.EndInvoke(result));// 如果異步處理時間過長,此處會阻塞線程,知道等到結果 } }
第三 異步回調
public class Program { static void Main() { Console.WriteLine("=====異步回調,不會阻塞,自動回調 ===="); AsyEventClass ac = new AsyEventClass(); AsyEventClass.AsyncEventHandler asy = new AsyEventClass.AsyncEventHandler(ac.ToDealData); IAsyncResult result=asy.BeginInvoke(num1, num2, new AsyncCallback(ac.Callback), asy);//處理完自動回調callback方法,不會造成線程阻塞 Console.WriteLine("此處不受影響,繼續執行"); } }