Go任务执行链核心是用统一TaskFunc接口（含context）、链式Builder构建可组合/中断/错误传递流程，支持errgroup并发、中间件扩展及context透传。
用 Go 构建任务执行链，核心是把多个异步或同步操作串成可组合、可中断、可错误传递的流程。不是简单地写一串 go func() {}()，而是让每个环节明确职责、控制流转、统一错误处理，并天然支持并发调度。
用函数类型定义任务节点
每个任务抽象为一个接受输入、返回输出和错误的函数：
- 类型定义如：
type TaskFunc func(ctx context.Context, input interface{}) (output interface{}, err error) - 所有任务签名一致，才能被统一编排；
input和output用interface{}保持灵活，实际中建议用具体结构体提升可读性 - 必须接收
context.Context，便于超时控制、取消传播和跨 goroutine 传值
用链式方法串联任务（Builder 模式）
不直接调用函数，而是通过链式调用构建执行序列：
- 定义一个
Chain结构体，内部维护任务切片：tasks []TaskFunc - 提供
Then(task TaskFunc) *Chain方法追加任务，返回自身实现链式调用 - 最后用
Run(ctx context.Context, initial interface{}) (interface{}, error)执行整条链：依次调用每个任务，前一个的output作为下一个的input - 任意任务返回非 nil error，立即终止后续执行并返回该错误
并发任务用 Go + WaitGroup 或 errgroup 控制
当某环节需并行执行多个子任务（如同时调用 3 个微服务），不要在 TaskFunc 内裸写 go，而应封装并发原语：
立即学习“go语言免费学习笔记（深入）”；
- 推荐使用
golang.org/x/sync/errgroup：自动收集第一个错误、共享上下文、等待全部完成 - 示例：在某个 TaskFunc 中启动
eg, ctx := errgroup.WithContext(parentCtx)，再用eg.Go(func() error { ... })添加并发子任务 - 避免手动管理
sync.WaitGroup和 channel，易出错且难统一错误处理
支持中间件与上下文透传
真实场景常需日志、重试、熔断、指标埋点等横切逻辑。可在链中插入中间件式任务：
- 写一个高阶函数：
func WithRetry(task TaskFunc, maxRetries int) TaskFunc，内部包装原始 task 并自动重试 - 用
context.WithValue在链中传递请求 ID、用户信息等，下游任务通过ctx.Value(key)获取 - 避免在每个 TaskFunc 中重复写日志或监控代码，统一在中间件里做
基本上就这些。Golang 链式并发流程不复杂但容易忽略 context 传递和错误短路机制——只要每个环节守好接口契约，链就能稳定跑起来。
