ET框架6.0分析二、异步编程

这篇具有很好参考价值的文章主要介绍了ET框架6.0分析二、异步编程。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

概述

ET框架很多地方都用到了异步,例如资源加载、AI、Actor模型等等。ET框架对C#的异步操作进行了一定程度的封装和改造,有一些特点:

  • 显式的或者说强调了使用C#异步实现协程机制(其实C#的异步编程天生就能实现这种用法)
  • 强制单线程异步
  • 没有使用C#库的Task,自己实现了ETTask等类
  • 实现了协程锁

为了更好的理解下面的内容,推荐先看一下之前写的这两篇文章:

  • 关于异步对CallbackHell的优化 跳转链接:《Lua CallbackHell优化》
  • 关于C#异步编程介绍和底层实现(最好看下,不然下面有些内容不太好理解) 跳转链接:《C# 异步编程async/await》

ETTask

C# 的异步函数有三个返回值(现在好像.NET7又多了一个ValueTask):Task,Task<T>,void,对应的,ET框架也一样对应实现了:ETTask,ETTask/,ETVoid,其实现相比C#简化了一些逻辑,并添加一些新的特性以适应ET框架,其实使用起来是差不多的。为了实现ETTask,也实现了对应AsyncTaskCompletedMethodBuilder的AsyncETTaskCompletedMethodBuilder等类(其实还C#原来的逻辑差不太多,有兴趣可以看下上述C# 异步编程的链接)。

ETTask添加了一些特性:

  • 支持对象池
  • 显式强调协程
[DebuggerHidden]
private async ETVoid InnerCoroutine()
{
    await this;
}

[DebuggerHidden]
public void Coroutine()
{
    InnerCoroutine().Coroutine();
}

可以看到这里的所谓协程Coroutine,其实等效于 await task,只是平平无奇的异步调用罢了

  • 异常消息打印

同步上线文 SynchronizationContext

C#异步编程在大多数情况下会使用多线程,ET的异步操作例如定时器等,使用多线程的开销相比较大,且ET框架是多进程,性能是分摊到多个进程中。所以ET使用了单线程的异步。

ThreadSynchronizationContext继承自SynchronizationContext,在构造初始化是会把自身设为当前SynchronizationContext.Current,重写了Post(异步消息分派到同步上下文)方法,来改写异步消息的分派到当前线程(就是进入队列)。

而异步函数在执行时,会获取当前上下文(__builder.AwaitUnsafeOnCompleted方法会调用GetCompletionAction,内部调用ExecutionContext.FastCapture(),这个方法内部捕获SynchronizationContext,感兴趣可以关键词搜索下)

public class ThreadSynchronizationContext : SynchronizationContext
{
    // 线程同步队列,发送接收socket回调都放到该队列,由poll线程统一执行
    private readonly ConcurrentQueue<Action> queue = new ConcurrentQueue<Action>();

    private Action a;

    public void Update()
    {
        while (true)
        {
            if (!this.queue.TryDequeue(out a))
            {
                return;
            }

            try
            {
                a();
            }
            catch (Exception e)
            {
                Log.Error(e);
            }
        }
    }

    public override void Post(SendOrPostCallback callback, object state)
    {
        this.Post(() => callback(state));
    }
    
    public void Post(Action action)
    {
        this.queue.Enqueue(action);
    }
}

public class MainThreadSynchronizationContext: Singleton<MainThreadSynchronizationContext>, ISingletonUpdate
{
    private readonly ThreadSynchronizationContext threadSynchronizationContext = new ThreadSynchronizationContext();

    public MainThreadSynchronizationContext()
    {
        SynchronizationContext.SetSynchronizationContext(this.threadSynchronizationContext);
    }
    
    public void Update()
    {
        this.threadSynchronizationContext.Update();
    }
    
    public void Post(SendOrPostCallback callback, object state)
    {
        this.Post(() => callback(state));
    }
    
    public void Post(Action action)
    {
        this.threadSynchronizationContext.Post(action);
    }
}

// MainThreadSynchronizationContext.Instance.Update()
Game.Update();

ThreadSynchronizationContex由包裹的MainThreadSynchronizationContext驱动更新,MainThreadSynchronizationContext是个单件,由外面驱动。更新Update方法会把队列里的委托取出执行。

SynchronizationContext

假设有两个线程,一个UI线程,一个后台线程,一个业务先在后台线程计算数据,然后在UI线程中刷新显示数据,显然不同的线程其上下文环境是不同的,两个线程的通信可以使用SynchronizationContext完成。
SynchronizationContext官方文档 https://learn.microsoft.com/zh-CN/dotnet/api/system.threading.synchronizationcontext?view=netcore-3.0

协程锁

多线程编程,对公共资源的访问要加锁,以保证数据访问的安全。类似的,在ET的异步编程中,从虽然上文中可以了解到ET的异步其实是单线程的,从代码运行的层面其实是一个线程以某种顺序处理一个个的任务,但是这种“顺序”并不可控。ET这里的协程锁其实就是使用某个key,对所有用这个key包裹的代码段推入一个队列,只有前面的代码段执行结束才能执行后面的代码。

这看起来和C#平时用的lock(object),其实只是用法上比较像,其实在实现细节是有根本的差距的:简单来说。ET实现的协程锁是一种用户态的锁,不会造成内核态/用户态的切换。而lock是一种C#语法糖,在编译时其实是通过Monitor监视器实现的,会涉及到内核转换。一个线程上可能会运行成百上千个协程,如果这个线程被挂起,那么有可能造成很多协程Delay,可能造成灾难性的后果。

结构类图:
ET框架6.0分析二、异步编程
时序图:
ET框架6.0分析二、异步编程
结合ET工程官方的一个用法:

public static async ETTask<T> Query<T>(this DBComponent self, long id, string collection = null) where T : Entity
{
    using (await CoroutineLockComponent.Instance.Wait(CoroutineLockType.DB, id % DBComponent.TaskCount))
    {
        IAsyncCursor<T> cursor = await self.GetCollection<T>(collection).FindAsync(d => d.Id == id);

        return await cursor.FirstOrDefaultAsync();
    }
}

可以看到协程锁是被using包裹的,即{}包裹的代码块运行结束,协程锁会被dispose。
先来看当第一次调用Wait时会直接返回,当第一次的锁没有被dispose时,后面获取锁时会进入队列。当前面的锁被dispose时,会通知队列中后面一个锁在下一次Update时被Notify,SetResult获取到锁,其所属的代码段得以执行。文章来源地址https://www.toymoban.com/news/detail-444981.html

到了这里,关于ET框架6.0分析二、异步编程的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Python异步编程之web框架 异步vs同步 Redis并发对比

    主题: 比较异步框架和同步框架在RedisIO操作的性能差异 python版本 :python 3.8 数据库 :redis 5.0.7 压测工具 :locust web框架 :同步:flask 异步:starlette 请求并发量 : 模拟10个用户 服务器配置 : Intel(R) i7-12700F 客户端配置 :Intel(R) i7-8700 3.20GHz flask是python中轻量级web框架,特点是灵

    2024年02月10日
    浏览(44)
  • web前端框架Javascript之JavaScript 异步编程史

    早期的 Web 应用中,与后台进行交互时,需要进行 form 表单的提交,然后在页面刷新后给用户反馈结果。在页面刷新过程中,后台会重新返回一段 HTML 代码,这段 HTML 中的大部分内容与之前页面基本相同,这势必造成了流量的浪费,而且一来一回也延长了页面的响应时间,总

    2024年02月14日
    浏览(54)
  • Python异步编程之web框架异步vs同步 无IO任务压测对比

    在python编程中,通过协程实现的异步编程号称能够提高IO密集型任务的并发量。本系列比较web服务器同步框架和异步框架的性能差异,包括无IO接口和常见IO操作,如文件、mysql、redis等。使用压测工具locust测试相同条件下两种编程模式能够处理请求的速度。 主题: 单纯比较异

    2024年02月06日
    浏览(49)
  • Python异步编程之web框架 异步vs同步 文件IO任务压测对比

    主题: 比较异步框架和同步框架在文件IO操作的性能差异 python版本 :python 3.8 压测工具 :locust web框架 :同步:flask 异步:aiohttp、starlette 异步文件模块 :aiofiles、anyio.Path 请求并发量 : 模拟10个用户 服务器配置 : Intel(R) i7-12700F 客户端配置 :Intel(R) i7-8700 3.20GHz flask是python中轻

    2024年02月06日
    浏览(114)
  • Python异步编程之web框架 异步vs同步 数据库IO任务并发支持对比

    主题: 比较异步框架和同步框架在数据库IO操作的性能差异 python版本 :python 3.8 数据库 :mysql 8.0.27 (docker部署) 压测工具 :locust web框架 :同步:flask 异步:starlette 请求并发量 : 模拟10个用户 服务器配置 : Intel(R) i7-12700F 客户端配置 :Intel(R) i7-8700 3.20GHz python中操作数据库通常

    2024年02月08日
    浏览(57)
  • Python异步编程之web框架 异步vs同步 数据库IO任务压测对比

    主题: 比较异步框架和同步框架在数据库IO操作的性能差异 python版本 :python 3.8 数据库 :mysql 8.0.27 (docker部署) 压测工具 :locust web框架 :同步:flask 异步:starlette 请求并发量 : 模拟10个用户 服务器配置 : Intel(R) i7-12700F 客户端配置 :Intel(R) i7-8700 3.20GHz python中操作数据库通常

    2024年02月08日
    浏览(90)
  • Unity常见框架探索-ET框架探索

    简介 ET框架是类ECS的一个Unity前后端框架 论坛地址为:https://et-framework.cn Git地址为:https://github.com/egametang/ET Unity程序集的使用 本文将会以7.2版本进行分析。所以直接clone github上的仓库,将工程导入到本地,之后将分支切换到最新的release分支,\\\"release7.2\\\" ET-ChangeDefine-ADD_ENABLE

    2024年02月09日
    浏览(37)
  • ET框架解读其一

    版本属于5.0 ECS? 真正的ECS属于是entity-component-system 组件里面只有数据没有方法,system里面是针对组件的方法,system通过查找只需要关注自己想关注的组件集合就可以。 但是ET框架的代码在组件里面写满了方法,有数据又有方法的组件,随时可拆卸,像什么?没错 是Unity的组

    2024年02月09日
    浏览(53)
  • ET框架(一)

    cmd 输入验证  dotnet --version   path :添加  cmd  输入mongo 验证 Unity 2020.3.35f1c2 安装Rider =》取消波浪线 show context action=》configtion ispection sevity 运行: 重新编译Unity mono和Client-Server 服务器日志: 打开Unity项目 设置为Mono 使用Tool-Buidl Code 重新编译  打包运行 发现打包报错: 安装

    2024年02月12日
    浏览(38)
  • .NET 6.0 中引入异步流(Async Streams)

    异步流(Async Streams):.NET 6.0 引入了异步流的概念,使得以异步方式产生和消费数据变得更加容易和高效。它可以通过 yield return 和 await foreach 语法进行操作,适用于处理大量数据或需要与慢速数据源交互的场景。 下面是一个使用异步流的简单示例: 在上述示例中, Genera

    2024年02月12日
    浏览(35)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包