zoukankan      html  css  js  c++  java
  • 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("此处不受影响,继续执行");
            }
            
    }
  • 相关阅读:
    oracle报ORA-00911:invalid character
    转: ㊣华哥日记㊣ 12.14-如何去了解更多的东西
    App竞品技术分析 (3)减小安装包的体积(转)
    ***apache做301重定向的方法
    .htaccess是什么?.htaccess几个简单应用
    一个网页如何决定是当前页打开还是新窗口打开?
    响应式web设计之CSS3 Media Queries
    ***CSS魔法堂:选择器及其优先级
    Bootstrap3 为何无法显示Glyphicons 图标
    MySQL中tinytext、text、mediumtext和longtext详解
  • 原文地址:https://www.cnblogs.com/MissQing/p/6479964.html
Copyright © 2011-2022 走看看