Skip to main content

Module progress

Module progress 

Source
Expand description

内存任务缓冲表:基于 DashMap 的执行任务注册中心。

异步执行模型:StartExec / StartExecStream 立即返回 task_id,容器在后台 tokio task 中运行。前端通过 GetExecResult 轮询 EXEC_TASKS 读取阶段与结果,或通过 SSE handler 取走 EXEC_STREAMS 的 receiver 做流式输出。任务条目在 TTL 过期后 由 gc_old_tasks 回收,避免内存无限增长。

Structs§

StreamEntry
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。