go轻量工作流引擎核心是精准控制流程生命周期五环节，基于dag状态机驱动，用结构体建模流程与任务，支持json/yaml声明式定义、interface任务类型、map[string]any输入输出、context超时隔离、panic捕获及可选持久化接口。
Go语言实现轻量级工作流引擎，核心不在堆功能，而在精准控制流程生命周期——定义、调度、执行、状态流转、错误恢复这五个环节必须环环相扣，且全部能嵌入单进程、无外部依赖地跑起来。
用结构体建模流程与任务
所有轻量引擎（如pro-workflow、FlowCue、conductor2）都把“流程”抽象为一个可序列化的结构体，通常包含ID、版本、节点列表、起始节点名等字段；每个“任务节点”则是一个带类型、输入映射、超时、重试策略的独立单元。关键不是字段多，而是这些字段必须能直接转成JSON/YAML，并支持从代码中声明式构造。例如：
- 用struct tag标记序列化字段，确保YAML/JSON定义能1:1映射到运行时对象
- 任务类型不硬编码为字符串，而是定义为interface{ Execute(ctx context.Context, input map[string]any) (map[string]any, error) }，便于注入任意业务逻辑
- 输入输出统一走map[string]any，不强求结构体，兼顾灵活性与调试友好性
基于DAG的状态机驱动执行
流程本质是有向无环图（DAG），引擎的核心循环就是“取当前就绪节点→执行→根据结果选下一条边→更新全局状态”。这不是靠数据库轮询，而是用内存状态机实时推进：
- 每个流程实例持有一个map[string]nodeState，记录每个节点的RUNNING/SUCCESS/FAILED/RETRYING状态
- 执行器每次只拉取所有前置节点已完成且自身未执行的节点（拓扑排序的简化版）
- 分支逻辑（如if-else）由节点自身的Next()函数动态返回目标节点名，而非静态配置死链
任务执行与上下文隔离
轻量不等于简陋，任务执行需有明确边界：超时控制、panic捕获、输入输出隔离、重试退避。Go的context和goroutine天然适配：
- 每个任务在独立context.WithTimeout下运行，超时自动cancel，不污染主流程上下文
- 用recover()捕获任务内panic，转为可记录、可重试的error，避免整个流程崩溃
- 输入数据通过深拷贝或不可变map传入，防止任务间意外共享状态
- 重试策略（如指数退避）封装为独立Option，按任务粒度配置，非全局开关
状态持久化与恢复可选但接口清晰
真正轻量的标志是“内存模式开箱即用，外接存储只需实现两个接口”：
- 定义Store接口：SaveWorkflowInstance / GetWorkflowInstance / ListWorkflowInstances
- 定义PubSub接口：Publish / Subscribe（用于跨进程通知节点完成）
- 默认提供in-memory store和channel-based pubsub，生产环境换Redis或SQLite只需替换实现，不改引擎核心
golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！
