Module async_runtime

Source
Expand description

§异步运行时超时机制改进

本模块为 ModuForge 异步运行时添加了全面的超时保护机制,解决了以下问题:

§主要改进

  1. 任务接收超时:防止 rx.recv().await 无限等待
  2. 中间件超时配置化:统一使用配置而非硬编码超时时间

§配置说明

通过 PerformanceConfig 可以配置各种超时时间:

use mf_core::async_runtime::PerformanceConfig;

let config = PerformanceConfig {
    enable_monitoring: true,
    middleware_timeout_ms: 1000,         // 中间件超时 1秒
    task_receive_timeout_ms: 5000,       // 任务接收超时 5秒
    ..Default::default()
};

§使用建议

  • 开发环境:使用较长的超时时间(如 10-30 秒)便于调试
  • 生产环境:使用较短的超时时间(如 1-5 秒)保证响应性
  • 高负载环境:根据实际性能测试调整超时时间

§错误处理

所有超时都会产生详细的错误信息,包含:

  • 超时的具体操作类型
  • 配置的超时时间
  • 便于调试的上下文信息

Structs§

ForgeAsyncRuntime
异步编�器运行时