Expand description
内存任务缓冲表:基于 DashMap 的执行任务注册中心。
异步执行模型:StartExec / StartExecStream 立即返回 task_id,容器在后台 tokio
task 中运行。前端通过 GetExecResult 轮询 EXEC_TASKS 读取阶段与结果,或通过
SSE handler 取走 EXEC_STREAMS 的 receiver 做流式输出。任务条目在 TTL 过期后
由 gc_old_tasks 回收,避免内存无限增长。
Structs§
- Stream
Entry - EXEC_STREAMS 条目:receiver + 创建时间(供 GC)。
Statics§
- EXEC_
STREAMS - 流式任务表:SSE handler 用 task_id 取出 receiver(一次性,取出即移除)。
- EXEC_
TASKS - 全局任务注册表。
Functions§
- gc_
old_ tasks - 回收超过
RUNNER_CONFIG.task_ttl_secs的历史任务。 - insert_
task - 创建一个排队中的新任务。
- update_
task_ result - 写入最终结果:状态置为「执行完毕」并填充 result。
- update_
task_ stage - 更新任务阶段(状态 + 描述),不改写 result。