ETTask 核心机制与技术实现ETTask 是 ET 框架自研的轻量级异步协程基元旨在解决 C# 原生Task在单线程游戏逻辑中存在的同步上下文SynchronizationContext开销大、内存分配频繁及回调地狱问题。它基于状态机原理配合对象池技术实现了零 GC 压力的高并发异步调度 。1. 核心设计原理ETTask 摒弃了 .NET 原生的SynchronizationContext机制采用单线程事件循环 续体直调的模式。特性维度C# 原生 TaskET 框架 ETTask优势解析调度机制依赖SynchronizationContext将续体Continuation封送回主线程涉及队列操作和委托分配 。无同步上下文。直接在当前单线程上下文中执行续体无需线程切换或队列排队 。消除线程上下文切换开销提升高频调用下的吞吐量。内存管理每次异步操作通常产生新的Task对象和闭包导致高频 GC 。对象池化。ETAsyncTaskMethodBuilder和Awaiter均从对象池复用大幅降低 GC 压力 。适合游戏服务器长运行场景避免内存抖动。执行模型多线程安全但需锁保护状态 。单线程专用。假设运行环境为单线程如 Fiber移除所有锁机制极致简化逻辑 。避免死锁风险代码执行路径更短。异常处理抛出AggregateException或直接抛异常需 try-catch 包裹 。内部集成异常捕获支持统一错误码返回适配游戏业务逻辑 。简化业务层的错误处理流程。2. 技术实现细节2.1 异步方法构建器 (ETAsyncTaskMethodBuilder)ET 框架重写了 C# 的异步状态机入口。当编译器遇到async ETTask方法时会使用ETAsyncTaskMethodBuilder而非原生的AsyncTaskMethodBuilder。启动阶段从对象池获取 Builder 实例初始化状态机。等待阶段当遇到await时检查被等待对象如 IO 操作是否完成。若未完成将当前状态机注册为回调并立即返回控制权给主循环若已完成直接同步执行后续代码 。恢复阶段IO 完成后通过OneThreadSynchronizationContext或直接调用Run()方法在无队列阻塞的情况下直接恢复状态机执行 。2.2 续体直调与零上下文原生await在恢复时会检查SynchronizationContext若有则通过Post方法将续体放入消息队列。ETTask 移除了这一层直调机制续体函数直接作为普通方法调用避免了委托封装和队列查找的开销 。单线程假设由于 ET 服务器每个进程Fiber是单线程运行的不需要考虑多线程竞争因此不需要锁来保护状态机的状态流转 。3. 代码实战与对比以下示例展示了如何使用 ETTask 处理登录逻辑并对比了其与原生 Task 的差异。using ET; using System.Threading.Tasks; // 【正确写法】ET 框架标准异步处理 // 返回值必须是 ETTask 或 ETTaskT严禁使用 void async 或 Task public class LoginHandler : AMRpcHandlerC2R_Login, R2C_Login { // 标记为 async返回类型为 ETTask protected override async ETTask Run(Session session, C2R_Login request, ActionR2C_Login response) { R2C_Login reply new R2C_Login(); try { // 1. 模拟数据库异步查询 // await 挂起当前纤程线程去处理其他请求不阻塞主线程 var accountInfo await AccountModel.GetAsync(request.account); if (accountInfo null) { reply.ErrorCode 101; response(reply); return; // 直接返回结束当前纤程 } // 2. 模拟跨进程 Actor 调用 // 内部自动处理消息序列化、发送、等待响应、反序列化 var gateKey await RealmActorComponent.Instance.GetGateKey(request.account); reply.GateKey gateKey; reply.ErrorCode 0; } catch (System.Exception e) { Log.Error(e); reply.ErrorCode 500; } // 3. 发送响应 response(reply); // 4. 显式释放 Session (根据业务需求) session.Dispose(); } } // 【错误示范】原生 Task 在 ET 中的潜在问题 public class BadLoginHandler { // 错误点返回 Task 会导致框架无法正确管理对象池和异常捕获 protected async Task RunBad(Session session) { // 错误点原生 Task 可能触发 SynchronizationContext 上下文切换增加不必要的开销 var data await Task.Delay(100); } }4. 关键注意事项与避坑指南在使用 ETTask 时必须严格遵守以下规范以避免内存泄漏或逻辑错误严禁混用 Task 与 ETTask所有异步方法返回值必须为ETTask或ETTaskT。若在async ETTask方法中await一个原生的Task虽然能编译通过但会失去对象池优化且可能引发上下文调度问题 。若必须调用返回Task的第三方库需使用task.ToETTask()扩展方法进行转换框架通常提供此类适配。避免 Async Void严禁使用async void。这会导致异常无法被框架捕获且无法追踪生命周期极易导致服务器崩溃或逻辑中断 。对象池回收意识虽然 ETTask 自动管理大部分资源但在手动创建复杂异步状态或自定义 Awaitable 对象时需确保实现IDisposable或在finally块中归还对象池防止内存泄漏 。异常传播机制ETTask 内部捕获的异常通常会封装到 Rpc 响应的ErrorCode中而不是直接抛出崩溃。开发者需在try-catch块中显式处理业务异常确保response回调一定被执行否则客户端将一直等待超时 。5. 总结ETTask 是 ET 框架高性能的基石之一。它通过去除同步上下文、引入对象池和单线程直调三大手段将 C# 的异步编程改造为适合游戏服务器的高性能协程模型。开发者只需遵循async ETTask的编码规范即可在享受async/await语法糖带来的线性代码可读性的同时获得接近原生同步代码的执行效率 。参考来源【ET框架】基础及实践难题解答ET服务器框架学习笔记-杂记ETTask,async,await什么是协程从回调嵌套到 ET 框架的 ETTask 异步模型ET框架协程进阶用 C async/await 与 TaskCompletionSource 告别回调地狱走向零同步上下文的 ETTaskET框架避坑指南Actor消息、ETTask异步与组件生命周期新手最易踩的10个坑ET框架协程进阶用 async/await 与 TaskCompletionSource 告别回调地狱理解 ETTask 的单线程异步设计 
长河君 · 2026/11/2 18:14:13 · 阅读 1.2k ETTask异步机制深度解析
ETTask 核心机制与技术实现ETTask 是 ET 框架自研的轻量级异步协程基元旨在解决 C# 原生Task在单线程游戏逻辑中存在的同步上下文SynchronizationContext开销大、内存分配频繁及回调地狱问题。它基于状态机原理配合对象池技术实现了零 GC 压力的高并发异步调度 。1. 核心设计原理ETTask 摒弃了 .NET 原生的SynchronizationContext机制采用单线程事件循环 续体直调的模式。特性维度C# 原生 TaskET 框架 ETTask优势解析调度机制依赖SynchronizationContext将续体Continuation封送回主线程涉及队列操作和委托分配 。无同步上下文。直接在当前单线程上下文中执行续体无需线程切换或队列排队 。消除线程上下文切换开销提升高频调用下的吞吐量。内存管理每次异步操作通常产生新的Task对象和闭包导致高频 GC 。对象池化。ETAsyncTaskMethodBuilder和Awaiter均从对象池复用大幅降低 GC 压力 。适合游戏服务器长运行场景避免内存抖动。执行模型多线程安全但需锁保护状态 。单线程专用。假设运行环境为单线程如 Fiber移除所有锁机制极致简化逻辑 。避免死锁风险代码执行路径更短。异常处理抛出AggregateException或直接抛异常需 try-catch 包裹 。内部集成异常捕获支持统一错误码返回适配游戏业务逻辑 。简化业务层的错误处理流程。2. 技术实现细节2.1 异步方法构建器 (ETAsyncTaskMethodBuilder)ET 框架重写了 C# 的异步状态机入口。当编译器遇到async ETTask方法时会使用ETAsyncTaskMethodBuilder而非原生的AsyncTaskMethodBuilder。启动阶段从对象池获取 Builder 实例初始化状态机。等待阶段当遇到await时检查被等待对象如 IO 操作是否完成。若未完成将当前状态机注册为回调并立即返回控制权给主循环若已完成直接同步执行后续代码 。恢复阶段IO 完成后通过OneThreadSynchronizationContext或直接调用Run()方法在无队列阻塞的情况下直接恢复状态机执行 。2.2 续体直调与零上下文原生await在恢复时会检查SynchronizationContext若有则通过Post方法将续体放入消息队列。ETTask 移除了这一层直调机制续体函数直接作为普通方法调用避免了委托封装和队列查找的开销 。单线程假设由于 ET 服务器每个进程Fiber是单线程运行的不需要考虑多线程竞争因此不需要锁来保护状态机的状态流转 。3. 代码实战与对比以下示例展示了如何使用 ETTask 处理登录逻辑并对比了其与原生 Task 的差异。using ET; using System.Threading.Tasks; // 【正确写法】ET 框架标准异步处理 // 返回值必须是 ETTask 或 ETTaskT严禁使用 void async 或 Task public class LoginHandler : AMRpcHandlerC2R_Login, R2C_Login { // 标记为 async返回类型为 ETTask protected override async ETTask Run(Session session, C2R_Login request, ActionR2C_Login response) { R2C_Login reply new R2C_Login(); try { // 1. 模拟数据库异步查询 // await 挂起当前纤程线程去处理其他请求不阻塞主线程 var accountInfo await AccountModel.GetAsync(request.account); if (accountInfo null) { reply.ErrorCode 101; response(reply); return; // 直接返回结束当前纤程 } // 2. 模拟跨进程 Actor 调用 // 内部自动处理消息序列化、发送、等待响应、反序列化 var gateKey await RealmActorComponent.Instance.GetGateKey(request.account); reply.GateKey gateKey; reply.ErrorCode 0; } catch (System.Exception e) { Log.Error(e); reply.ErrorCode 500; } // 3. 发送响应 response(reply); // 4. 显式释放 Session (根据业务需求) session.Dispose(); } } // 【错误示范】原生 Task 在 ET 中的潜在问题 public class BadLoginHandler { // 错误点返回 Task 会导致框架无法正确管理对象池和异常捕获 protected async Task RunBad(Session session) { // 错误点原生 Task 可能触发 SynchronizationContext 上下文切换增加不必要的开销 var data await Task.Delay(100); } }4. 关键注意事项与避坑指南在使用 ETTask 时必须严格遵守以下规范以避免内存泄漏或逻辑错误严禁混用 Task 与 ETTask所有异步方法返回值必须为ETTask或ETTaskT。若在async ETTask方法中await一个原生的Task虽然能编译通过但会失去对象池优化且可能引发上下文调度问题 。若必须调用返回Task的第三方库需使用task.ToETTask()扩展方法进行转换框架通常提供此类适配。避免 Async Void严禁使用async void。这会导致异常无法被框架捕获且无法追踪生命周期极易导致服务器崩溃或逻辑中断 。对象池回收意识虽然 ETTask 自动管理大部分资源但在手动创建复杂异步状态或自定义 Awaitable 对象时需确保实现IDisposable或在finally块中归还对象池防止内存泄漏 。异常传播机制ETTask 内部捕获的异常通常会封装到 Rpc 响应的ErrorCode中而不是直接抛出崩溃。开发者需在try-catch块中显式处理业务异常确保response回调一定被执行否则客户端将一直等待超时 。5. 总结ETTask 是 ET 框架高性能的基石之一。它通过去除同步上下文、引入对象池和单线程直调三大手段将 C# 的异步编程改造为适合游戏服务器的高性能协程模型。开发者只需遵循async ETTask的编码规范即可在享受async/await语法糖带来的线性代码可读性的同时获得接近原生同步代码的执行效率 。参考来源【ET框架】基础及实践难题解答ET服务器框架学习笔记-杂记ETTask,async,await什么是协程从回调嵌套到 ET 框架的 ETTask 异步模型ET框架协程进阶用 C async/await 与 TaskCompletionSource 告别回调地狱走向零同步上下文的 ETTaskET框架避坑指南Actor消息、ETTask异步与组件生命周期新手最易踩的10个坑ET框架协程进阶用 async/await 与 TaskCompletionSource 告别回调地狱理解 ETTask 的单线程异步设计