C#异步编程由浅入深(三)之详解Awaiter

 更新时间:2022年03月04日 10:01:43   作者:白烟染黑墨  
这篇文章主要介绍了C#异步编程由浅入深(三)之详解Awaiter,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下

  上一篇末尾提到了Awaiter这个类型,上一篇说了,能await的对象,必须包含GetAwaiter()方法,不清楚的朋友可以看上篇文章。那么,Awaiter到底有什么特别之处呢?
  首先,从上篇文章我们知道,一个Awaiter必须实现INotifyCompletion接口,这个接口定义如下:

namespace System.Runtime.CompilerServices
{
    /// <summary>
    /// Represents an operation that will schedule continuations when the operation completes.
    /// </summary>
    public interface INotifyCompletion
    {
        /// <summary>Schedules the continuation action to be invoked when the instance completes.</summary>
        /// <param name="continuation">The action to invoke when the operation completes.</param>
        /// <exception cref="System.ArgumentNullException">The <paramref name="continuation"/> argument is null (Nothing in Visual Basic).</exception>
        void OnCompleted(Action continuation);
    }
}

  除此之外还必须包含IsCompleted属性和包含GetResult()方法。
  注意OnCompleted的参数是一个Action委托,并且不出意外的话,委托里面总会有一个地方调用一个MoveNext()方法,它推动状态机到达下一个状态,然后执行下一个状态需要执行的代码。
  那么,知道这个有什么用呢?第一,它是你充分了解async/await这套机制的基础,包括与之相关的同步上下文、执行上下文、死锁问题等,第二,它可以实现一些特殊的功能。
  从上一篇我们知道,OnCompleted中的contination的主要目的是推动状态机的执行,也就是推动异步方法中await后面部分的代码执行。从这里看出,continuation的执行是受我们控制的,因此我们可以直接执行它,或是等待某个条件成熟然后执行它,我们可以把它放到线程池执行,也可以单独起一个线程执行。譬如,我们可以让await后面部分的代码直接在线程池上执行。

public static async Task AwaiterTest()
{
    Console.WriteLine($"是否是线程池线程?{Thread.CurrentThread.IsThreadPoolThread}");
    await default (SkipToThreadPoolAwaiter);
    Console.WriteLine($"是否是线程池线程?{Thread.CurrentThread.IsThreadPoolThread}");
}

static void Main(string[] args)
{
    _ = AwaiterTest();
    Console.ReadLine();
}

public struct SkipToThreadPoolAwaiter : INotifyCompletion
{
    public bool IsCompleted => false;
    public void GetResult() 
    {
        Console.WriteLine("调用GetResult以获取结果");
    }
    public void OnCompleted(Action continuation)
    {
        Console.WriteLine("调用OnCompleted,把Await后面部分要执行的代码传递过来(传递MoveNext,以推动状态机流转)");
        ThreadPool.QueueUserWorkItem(state =>
        {
            Console.WriteLine("开始执行Await后面部分的代码");
            continuation();
            Console.WriteLine("后面部分的代码执行完毕");
        });
        Console.WriteLine("返回调用线程");
    }

    public SkipToThreadPoolAwaiter GetAwaiter()
    {
        Console.WriteLine("获得Awaiter");
        return this;
    }
}

  这是一个控制台程序,输出结果如下。

是否是线程池线程?False
获得Awaiter
调用OnCompleted,把Await后面部分要执行的代码传递过来(传递MoveNext,以推动状态机流转)
返回调用线程
开始执行Await后面部分的代码
调用GetResult以获取结果
是否是线程池线程?True
后面部分的代码执行完毕

  特别注意一下,第五步说明可能有点疑惑,怎么第六步不是打印是否是线程池线程?原因是部分awaiter是有返回值的,在执行await后面部分的代码时,会首先调用GetResult()以获取结果。这对编译器改造异步方法来说是一个固定的模式(上篇文章没有体现这一步)。
  把Awaiter改成有返回值尝试。

public static async Task AwaiterTest()
{
    Console.WriteLine($"是否是线程池线程?{Thread.CurrentThread.IsThreadPoolThread}");
    var res = await default (SkipToThreadPoolAwaiter);
    Console.WriteLine($"结果是{res}");
}

static void Main(string[] args)
    _ = AwaiterTest();
    Console.ReadLine();
public struct SkipToThreadPoolAwaiter : INotifyCompletion
    public bool IsCompleted => false;
    public int GetResult() 
    {
        Console.WriteLine("调用GetResult以获取结果");
        return 1;
    }
    public void OnCompleted(Action continuation)
        Console.WriteLine("调用OnCompleted,把Await后面部分要执行的代码传递过来(传递MoveNext,以推动状态机流转)");
        ThreadPool.QueueUserWorkItem(state =>
        {
            Console.WriteLine("开始执行Await后面部分的代码");
            continuation();
            Console.WriteLine("后面部分的代码执行完毕");
        });
        Console.WriteLine("返回调用线程");
    public SkipToThreadPoolAwaiter GetAwaiter()
        Console.WriteLine("获得Awaiter");
        return this;

  输出如下

是否是线程池线程?False
获得Awaiter
调用OnCompleted,把Await后面部分要执行的代码传递过来(传递MoveNext,以推动状态机流转)
返回调用线程
开始执行Await后面部分的代码
调用GetResult以获取结果
结果是1
是否是线程池线程?True
后面部分的代码执行完毕

  对照前面的文章来看,相信你应该有所得,能解决你部分的疑惑。前面说到,我们可以控制continuation的执行,那如果当前线程有同步上下文(SychronizationContext),我们是不是可以放到同步上下文中执行?TaskAwaiter是会这么做的,如果你不想它使用同步上下文,你可以在Task实例上调用ConfigureAwait(false),它表面后面部分的代码将不会使用同步上下文执行。
  另外说一下Task.Yield()这个Awaiter,他的行为是捕捉同步上下文,如果有,则会放到同步上下文中执行,如果没有,则会放到线程池中执行。在窗体程序中,有时候你打开一个模态对话框,会导致主窗体部分的动画没有反应,在模态对话框关闭之后,才会反应。原因是模态对话框阻塞了主窗体的消息循环,也就是阻塞了主线程,如果想让动画先完成,然后再打开模态对话框,则可以在打开模态对话框之前,Await Task.Yield(),这也对应了它的意思,让渡之意。
  后面文章还会说明同步上下文具体是什么、异步代码中使用同步代码会导致死锁的本质原因、如何实现类似Task的类,并且怎么与Async/await这套机制搭配使用等知识。
  觉得有收获的不妨点个赞,有支持才有动力写出更好的文章。

到此这篇关于C#异步编程由浅入深(三)细说Awaiter的文章就介绍到这了,更多相关C#异步编程Awaiter内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • c#中xml文档注释编译dll引用到其它项目示例

    c#中xml文档注释编译dll引用到其它项目示例

    这篇文章主要介绍了c#中xml文档注释编译dll引用到其它项目示例,需要的朋友可以参考下
    2014-02-02
  • C#如何调用MFC 窗口 DLL

    C#如何调用MFC 窗口 DLL

    这篇文章主要介绍了C#如何调用MFC 窗口 DLL,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-04-04
  • C#中Foreach循环遍历的本质与枚举器详解

    C#中Foreach循环遍历的本质与枚举器详解

    这篇文章主要给大家介绍了关于C#中Foreach循环遍历本质与枚举器的相关资料,foreach循环用于列举出集合中所有的元素,foreach语句中的表达式由关键字in隔开的两个项组成,本文通过示例代码介绍的非常详细,需要的朋友可以参考下
    2021-08-08
  • 详解Unity中的ShaderGraph入门使用教程

    详解Unity中的ShaderGraph入门使用教程

    Unity2018版本之后推出了一个可编程渲染管线工具ShaderGraph,让我们可以通过可视化界面拖拽来实现着色器的创建和编辑,今天重点给大家介绍Unity中的ShaderGraph入门使用教程,需要的朋友参考下吧
    2021-07-07
  • C#短消息提示窗口位置及窗口大小详解

    C#短消息提示窗口位置及窗口大小详解

    在我们的生活中无论是使用QQ,360安全卫士等软件的过程中,经常会遇到从右下方的托盘处弹出一个消息提示窗,比如新闻,产品更新等内容,下面这篇文章主要给大家介绍了关于C#短消息提示窗口位置及窗口大小的相关资料,需要的朋友可以参考下
    2022-12-12
  • C# form-data上传图片流到远程服务器的详细代码

    C# form-data上传图片流到远程服务器的详细代码

    这篇文章主要介绍了C# form-data上传图片流到远程服务器的详细代码,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-08-08
  • 浅谈C#设计模式之代理模式

    浅谈C#设计模式之代理模式

    这篇文章主要介绍了浅谈C#设计模式之代理模式,需要的朋友可以参考下
    2014-12-12
  • C#实现启用与禁用本地网络的方式小结【3种方式】

    C#实现启用与禁用本地网络的方式小结【3种方式】

    这篇文章主要介绍了C#实现启用与禁用本地网络的方式,结合实例形式总结分析了使用Hnetcfg.dll、Shell32.dll及setupapi.dll三种启用与禁用本地网络的操作方法,需要的朋友可以参考下
    2016-07-07
  • C#远程发送和接收数据流生成图片的方法

    C#远程发送和接收数据流生成图片的方法

    这篇文章主要介绍了C#远程发送和接收数据流生成图片的方法,涉及C#通过数据流传输图片的相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下
    2015-07-07
  • C#网络编程之Socket编程

    C#网络编程之Socket编程

    本文详细讲解了C#网络编程的Socket编程,文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-02-02

最新评论