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("此处不受影响,继续执行");
            }
            
    }
  • 相关阅读:
    sql over(partition by) 开窗函数的使用
    利用curl函数处理GET数据获取微信公众号的access_token
    2018.4.12
    字段和属性
    C#实现回车键登录
    判断DataTable里面数据是否有重复数据
    一个强大的人民币大写转换的正则表达式
    C#将image中的显示的图片转换成二进制
    遍历Dev LayoutControl中的所有控件信息
    遍历窗体中所有控件的信息
  • 原文地址:https://www.cnblogs.com/MissQing/p/6479964.html
Copyright © 2011-2022 走看看