复合型异步执行器需实现状态机驱动、分层取消与钩子监听:维护Idle/Running/Cancelled等原子化状态,用弱引用事件防泄漏;按分支创建子CancellationTokenSource并组合取消信号;提供BeforeStep/OnProgress等可插拔钩子;通过IAsyncEnumerable推送增量结果并自动终止流。

手动实现一个支持“状态监听”与“逻辑分支取消”的复合型异步执行器,核心在于将任务生命周期控制(如运行中、完成、取消)与可中断的执行路径解耦,并提供外部可观测和可干预的能力。关键不在于封装 async/await,而在于构建可响应、可组合、可诊断的状态驱动执行模型。
定义清晰的状态机与事件契约
执行器内部需维护明确的状态枚举(如 Idle、Running、Cancelling、Cancelled、Completed、Failed),并对外暴露只读状态属性和状态变更事件(如 StateChanged)。所有状态跃迁必须原子化,避免竞态。
- 使用
Interlocked.CompareExchange或Monitor.TryEnter保障状态写入线程安全 - 状态变更事件应采用弱引用事件管理器(如
WeakEventManager),防止 UI 控件泄漏 - 每个状态变更附带上下文快照(如当前步骤索引、已耗时、错误码),便于调试回溯
支持多级逻辑分支的协作式取消
“逻辑分支取消”指任务可按语义层级中断:例如主流程取消时,子任务 A 立即终止,但子任务 B 允许优雅收尾(如保存临时数据)。这需将 CancellationToken 按作用域分层传递,而非全局共享单一 token。
- 主执行器创建根
CancellationTokenSource,其 token 用于控制整体生命周期 - 为每个逻辑分支(如网络请求、本地计算、UI 更新)创建子
CancellationTokenSource,通过token.CreateLinkedTokenSource(rootToken, branchToken)组合取消信号 - 分支内主动检查
token.IsCancellationRequested,并在关键节点(如循环迭代前、IO 调用前)抛出OperationCanceledException - 主流程捕获分支异常后,根据分支策略决定是跳过、重试,还是终止整个执行链
提供可插拔的状态监听与钩子机制
监听不应仅限于状态值变化,还需覆盖执行过程中的关键节点,如“即将进入步骤3”、“第2次重试开始”、“进度达到75%”。为此,执行器需内置标准化钩子点(Hook Point)。
- 定义泛型钩子委托类型:
Action<hookcontext>></hookcontext>,其中HookContext包含时间戳、步骤名、输入参数、自定义元数据 - 预置常用钩子:BeforeStep、AfterStep、OnProgress、OnRetry、OnCancelRequested、OnException
- 允许用户通过
AddHook("BeforeStep", ctx => { ... })动态注册,支持条件过滤(如仅监听某类步骤) - 钩子执行失败默认不中断主流程,但记录警告日志;可配置为“强钩子”以启用故障传播
集成进度反馈与增量结果流
状态监听需与执行过程深度协同。若任务产出中间结果(如分页查询的每页数据、图像处理的逐帧输出),执行器应将这些结果作为状态的一部分推送出去,而非仅靠轮询。
- 内部维护
IAsyncEnumerable<tincrementalresult></tincrementalresult>流,由执行逻辑通过yield return或ChannelWriter推送 - 对外暴露
Results属性(只读序列),同时触发ResultAvailable事件 - 支持按需订阅:UI 可绑定到结果流做实时渲染,日志模块可消费全部结果做审计存档
- 当取消发生时,自动关闭结果流并标记最后一条结果为“终止标记”,避免消费者等待无响应流

















