zoukankan      html  css  js  c++  java
  • C#基础:线程之异步回调(委托)

     异步回调,什么是异步回调?我是这样理解的,当主线程在执行一段代码的时候,我们用委托执行了一个线程,这个线程要返回一个结果,关键是什么时候返回这个结果,异步回调就是在这个线程执行完成后立即返回这个线程的结果,然后继续执行主线程的方法。

          在讨论异步回调之前我们先依次来讨论一下同步执行和异步执行,最后来讨论异步回调。

    一、同步执行

          同步执行:在主线程执行的时候,主线程调用一个其它方法,此时主线程阻塞,等待调用方法执行完成后主线程才能继续执行。

      下面是同步执行的流程图

      接下来看看代码中的同步执行

    复制代码
            static void Main(string[] args)
            {
                #region 同步执行
                for (int i = 0; i < 100; i++)
                {
                    if (i == 50)
                    {
                        Console.Write("调用方法TakeAWhile并等待方法执行完成。");
                        TakeAWhile(1, 3000);
                        Console.Write("方法TakeAWhile执行完成。。。");
                    }
                    Thread.Sleep(30);
                    Console.Write(".");
                }
                #endregion
            }
            static int TakeAWhile(int data, int ms)
            {
                Thread.Sleep(ms);
                return ++data;
            }
    复制代码

    二、异步执行:

      异步执行:在主线程在执行的时候,打开一个子线程,主线程继续执行,当主线程需要子线程运行的结果的时候,主线程直接调用子线程运行结果,如果在调用的时候子线程还没有执行完成,主线程等待,直到子线程执行完成,主线程再继续执行。

      下面是异步执行的流程图

      接下来我们看看代码中的异步执行

    复制代码
            static void Main(string[] args)
            {
                #region 异步执行
                Func<int, int, int> d2 = TakeAWhile;
                IAsyncResult ar = d2.BeginInvoke(1, 3000, null, null);
                while (!ar.IsCompleted)
                {
                    Console.Write(".");
                    Thread.Sleep(50);
                }
                int result = d2.EndInvoke(ar);
                Console.Write("result:{0}",result);
                #endregion
            }
            static int TakeAWhile(int data, int ms)
            {
                Console.Write("TakesAWhile started");
                Thread.Sleep(ms);
                Console.WriteLine("TakeAWhile Completed");
                return ++data;
            }
    复制代码

    三、异步回调

             异步回调:主线程在执行的时候,打开一个子线程,主线程继续执行,当子线程执行完成的时候,主线程立即输出主线程的运行结果,主线程继续执行。

             下面是异步回调执行的流程图

      接下来我们看看代码中的异步回调

      

    复制代码
    static void Main(string[] args)
            {
                #region 异步回调
                Func<int, int, int> dl = TakeAWhile;
                dl.BeginInvoke(1, 3000, TakesAWhileCompleted, dl);
                for (int i = 0; i < 100; i++)
                {
                    Console.Write(".");
                    Thread.Sleep(50);
                }
                #endregion
            }
            static int TakeAWhile(int data, int ms)
            {
                Console.Write("TakesAWhile started");
                Thread.Sleep(ms);
                Console.WriteLine("TakeAWhile Completed");
                return ++data;
            }
            static void TakesAWhileCompleted(IAsyncResult ar)
            {
                if (ar == null)
                    throw new ArgumentNullException("ar");
                Func<int, int, int> dl = (Func<int, int, int>)ar.AsyncState;
                int result = dl.EndInvoke(ar);
                Console.WriteLine("Result:{0}",result);
            }
    复制代码
  • 相关阅读:
    Python re 模块中,如何使用反斜杠 ""分割字符串?
    VisualVM使用:Local Applications Cannot Be Detected
    九、Delphi10.3通过Json.Serializers实现反序列号,将JSON转换成数组
    vue项目 通过配置webpack插件DllPlugin进行打包速度优化,以及本地运行编译速度优化
    企业微信小程序 导购快捷联系用户 wx.qy.openUserProfile 的使用示例
    微信 支付即服务 服务人员注册 和 AEAD_AES_256_GCM 的使用 (sodium_crypto_aead_aes256gcm_decrypt 或者 sodium_crypto_aead_aes256gcm_is_available() )无法使用 的解决方案
    git仓库服务搭建
    配置中心 ------- Nacos
    Feign的介绍和使用
    Ribbon + Nacos 自定义负载均衡算法
  • 原文地址:https://www.cnblogs.com/asdyzh/p/9794594.html
Copyright © 2011-2022 走看看