结论：高阶函数封装节点+邻接表+拓扑排序可实现并发安全、可中断、可重试的DAG调度；goroutine链式调用因依赖丢失、错误不可捕获、context不透传等问题失效。
直接说结论：用高阶函数封装节点执行逻辑，配合邻接表 + 拓扑排序调度器，能实现并发安全、可中断、可重试的 DAG 任务调度；但goroutine不能直接串节点，context.Context必须逐节点透传，否则超时和取消会失效。
为什么不能用闭包+goroutine链式调用模拟DAG
常见错误是写成 go func() { stepA(); go func() { stepB() }() }() 这类嵌套 —— 看似并发，实则依赖丢失、错误不可捕获、无法拓扑校验。
- 节点间数据靠闭包变量传递，类型不约束，panic 后无兜底
- 没有入度/出度记录，加个“条件跳过B”就得重写整个 goroutine 链
-
context.WithTimeout只在最外层生效，stepB 超时不会触发 cancel，反而拖垮整个流程 - 重启后所有正在运行的
goroutine全丢，无状态快照可恢复
高阶函数怎么定义节点才真正解耦调度与执行
每个节点必须是纯函数签名：func(ctx context.Context, data map[string]interface{}) (map[string]interface{}, error)，且禁止内部调用其他节点。
- 输入
data是上一节点输出合并后的键值映射，不是结构体或全局状态 - 返回
error触发重试或失败分支，返回nil才推进到下一组节点 - 函数体里不能出现
go xxx()或channel ，所有并发由调度器统一控制 - 若需异步IO（如HTTP调用），必须用
ctx做超时控制，例如http.DefaultClient.Do(req.WithContext(ctx))
并发执行时如何避免竞态和重复调度
拓扑序只保证执行顺序，不保证并发安全 —— 多个叶子节点并行跑时，共享 data 会被并发读写。
立即学习“go语言免费学习笔记（深入）”；
- 调度器对每个节点执行前，必须深拷贝
data，防止 A、B 节点同时修改data["result"] - 节点间通信不走共享内存，而靠调度器聚合输出：A 输出
{"a":1}，B 输出{"b":2}，合并为{"a":1,"b":2}再传给 C - 使用
sync.WaitGroup+chan error收集并发节点结果，任一失败就短路后续，不等全部完成 - 避免用
map[string]interface{}直接作为参数传入多个 goroutine —— 它不是并发安全的，改用sync.Map或序列化后再解包
环检测和拓扑序生成容易被忽略的细节
加载完邻接表 map[string][]string 后，必须立刻做 DFS 环检测，并带路径报错，否则上线后才发现循环依赖，整个流程卡死。
- 检测函数要返回具体环路，例如
"cycle detected: 'validate' → 'enrich' → 'validate'"，不能只报"graph has cycle" - 拓扑序不能只靠入度减法，得用 DFS 或 Kahn 算法输出完整线性序列，用于后续按序分发节点
- 同一层级的多个节点（入度同时为 0）才能并发，不能把整个图 flatten 成一维 slice 就扔进
for range启 goroutine - 如果某节点有多个前置依赖（如 C 依赖 A 和 B），必须等 A、B 都成功完成后，才将 C 加入待执行队列
真正难的不是写一个能跑的 DAG，而是让每个节点的 ctx 生效、data 不乱、失败能定位、重启能续跑 —— 这些都藏在调度器对高阶函数的调用封装里，而不是节点函数本身。
