c#異步線程:同步調用,異步調用,異步回調


定義一個異步線程類:

  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("此處不受影響,繼續執行");
        }
        
}

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM