zoukankan      html  css  js  c++  java
  • C#语法——await与async的正确打开方式

    C#5.0推出了新语法,await与async,但相信大家还是很少使用它们。关于await与async有很多文章讲解,但有没有这样一种感觉,你看完后,总感觉这东西很不错,但用的时候,总是想不起来,或者不知道该怎么用。

    为什么呢?我觉得大家的await与async的打开方式不正确。

     正确的打开方式

     
    首先看下使用约束。

    1、await 只能在标记了async的函数内使用。

    2、await 等待的函数必须标记async。

    有没有感觉这是个循环?没错,这就是个循环。这也就是为什么大家不怎么用他们的原因。这个循环很讨厌,那么怎么破除这个循环呢?

    【很简单,await等待的是线程,不是函数。】

    不理解吗?没关系,接着看下去。

    下面从头来讲解,首先看这么一组对比

    public static int NoAsyncTest()
    {
       return 1;
    }
    public static async Task<int> AsyncTest()
    { 
      return 1;
    }

     async Task<int>等于int

    这意味着我们在正常调用这两个函数时,他们是等效的。那么用async Task<int>来修饰int目的是什么呢?

    目的是为了让这个方法这样被调用 await AsyncTest(),但直接这样调用,并不会开启线程,那这样费劲的修饰是不是就没什么意义了呢。

    当然不是,那什么时候会让 await AsyncTest()有意义呢?

    我们接着往下看,修改AsyncTest如下。然后,此时再调用await AsyncTest(),你会神奇的发现,依然没有卵用。。。

    Excute方法正常执行,而AsyncTest内运行的线程,自己执行自己的。

    public static async void Excute()
     {
           Console.WriteLine(Thread.CurrentThread.GetHashCode() + " 开始 Excute " + DateTime.Now);
           await AsyncTest();
           Console.WriteLine(Thread.CurrentThread.GetHashCode() + " 结束 Excute " + DateTime.Now);
     }
    
     public static async Task<int> AsyncTest()
     {
            Task.Run(() =>
                {
                    Console.WriteLine(Thread.CurrentThread.GetHashCode() + " Run1 " + DateTime.Now);
                    Thread.Sleep(1000);
                });
                return 1;
     }

    别着急,我们稍作调整,在线程后面增加.GetAwaiter().GetResult()。这句话是干什么用的呢?是用来获取线程返回值的。

    这个逻辑是这样的,如果想要获取线程返回结果,就自然要等待线程结束。

    运行一下,我们将看下面的结果。

    public static async Task<int> AsyncTest()
            {
                Task.Run(() =>
                {
                    Console.WriteLine(Thread.CurrentThread.GetHashCode() + " Run1 " + DateTime.Now);
                    Thread.Sleep(1000);
                }).GetAwaiter().GetResult();
                return 1;
            }
    

     

    但是,好像await AsyncTest();还是没启作用。没错,事实就是,他真的不会起作用。。。

    那么怎么才能让他起作用呢?

    首先,我们定义一个普通函数,他的返回值是一个Task,然后我们得到Task后,运行它,再用await等待这个Task。

    于是我们就得到这样的结果。

     public static async void Excute()
            {
                Console.WriteLine(Thread.CurrentThread.GetHashCode() + " 开始 Excute " + DateTime.Now);
                var waitTask = AsyncTestRun();
                waitTask.Start();
                int i = await waitTask;
                Console.WriteLine(Thread.CurrentThread.GetHashCode() + " i " + i);
                Console.WriteLine(Thread.CurrentThread.GetHashCode() + " 结束 Excute " + DateTime.Now);
            }
            public static Task<int> AsyncTestRun()
            {
                Task<int> t = new Task<int>(() => {
                    Console.WriteLine(Thread.CurrentThread.GetHashCode() + " Run1 " + DateTime.Now);
                    Thread.Sleep(1000);
                    return 100;
                });
                return t;
            }
    

      

    如图,这样写await AsyncTest();就起作用了。

    所以,还是那句话,await等待的是线程,不是函数。

    但在图里,我们发现很奇怪的一点,结束Excute也是线程3,而不是线程1。也就是说,Await会对线程进行优化。

    下面看下两组代码的对比,让我们就更清楚的了解下Await。

    第一组,使用await等待线程。

    public static async void Excute()
    {
       Console.WriteLine(Thread.CurrentThread.GetHashCode() + " 开始 Excute " + DateTime.Now);
       await SingleAwait(); 
       Console.WriteLine(Thread.CurrentThread.GetHashCode() + " 结束 Excute " + DateTime.Now);
    }
          
    public static async Task SingleAwait()
    {
         Console.WriteLine(Thread.CurrentThread.GetHashCode() + " AwaitTest开始 " + DateTime.Now);
         await Task.Run(() =>
                {
                    Console.WriteLine(Thread.CurrentThread.GetHashCode() + " Run1 " + DateTime.Now);
                    Thread.Sleep(1000);
                });
                await Task.Run(() =>
                {
                    Console.WriteLine(Thread.CurrentThread.GetHashCode() + " Run2 " + DateTime.Now);
                    Thread.Sleep(1000);
                });
                Console.WriteLine(Thread.CurrentThread.GetHashCode() + " AwaitTest结束 " + DateTime.Now);
                return;
    }
    

    第二组,使用等待线程结果,等待线程。

     public static async void Excute()
    {
         Console.WriteLine(Thread.CurrentThread.GetHashCode() + " 开始 Excute " + DateTime.Now);
                await SingleNoAwait(); 
         Console.WriteLine(Thread.CurrentThread.GetHashCode() + " 结束 Excute " + DateTime.Now);
            }
    public static async Task SingleNoAwait()
    {
          Console.WriteLine(Thread.CurrentThread.GetHashCode() + " SingleNoAwait开始 " + DateTime.Now);
           Task.Run(() =>
            {
                    Console.WriteLine(Thread.CurrentThread.GetHashCode() + " Run1 " + DateTime.Now);
                    Thread.Sleep(1000);
                }).GetAwaiter().GetResult();
                Task.Run(() =>
                {
                    Console.WriteLine(Thread.CurrentThread.GetHashCode() + " Run2 " + DateTime.Now);
                    Thread.Sleep(1000);
                }).GetAwaiter().GetResult();
                Console.WriteLine(Thread.CurrentThread.GetHashCode() + " SingleNoAwait结束 " + DateTime.Now);
                return;
    }
    

    可以明确的看到,第二组,线程重新回到了主线程1中,而第一组,已经被优化到了线程4中。

     结语

    await是一种很便捷的语法,他的确会让代码简洁一些,但他主动优化线程的功能,如果不了解就使用,可能会导致一些奇怪的BUG发生。

    这也是官方为什么只提供了await调用服务的例子,因为,在程序内调用,await还是要了解后,再使用,才安全。

    C#语法——委托,架构的血液

    C#语法——元组类型

    C#语法——泛型的多种应用

    ----------------------------------------------------------------------------------------------------

    注:此文章为原创,任何形式的转载都请联系作者获得授权并注明出处!
    若您觉得这篇文章还不错,请点击下方的推荐】,非常感谢!

     

  • 相关阅读:
    Solution -「ARC 126F」Affine Sort
    Solution -「ABC 219H」Candles
    Solution -「LOCAL」二进制的世界
    Solution Set -「ABC 217」
    Java 封装
    Java 对象和类
    Java 继承
    牛客网MySQL在线编程
    Linux uniq命令
    Linux 单引号、双引号、反引号
  • 原文地址:https://www.cnblogs.com/kiba/p/9292904.html
Copyright © 2011-2022 走看看