在Golang的并发编程中，context是用来在goroutine之间传递截止时间、取消信号以及请求范围数据的重要工具，其传播机制直接决定了并发任务的控制效果。当我们在主goroutine中创建context，再启动多个子goroutine时，context会按照特定的规则传递到各个子任务中，对应的取消信号也会同步生效。
context的基本传播规则
context的核心传播逻辑是：如果一个context被取消，那么所有从它派生出来的子context都会被同步取消。我们在传递context时，通常会将父context作为参数传入子goroutine，再通过context.WithCancel、context.WithTimeout等方法派生出子context，子context会继承父context的取消信号和截止时间。
普通goroutine中的传播示例
下面的代码展示了在普通goroutine中context的传播过程：
package main
import (
"context"
"fmt"
"time"
)
func subTask(ctx context.Context, taskID int) {
// 监听context的Done通道，判断是否需要取消任务
select {
case <-ctx.Done():
fmt.Printf("任务%d收到取消信号，退出执行n", taskID)
return
case <-time.After(3 * time.Second):
fmt.Printf("任务%d执行完成n", taskID)
}
}
func main() {
// 创建可取消的父context
parentCtx, cancel := context.WithCancel(context.Background())
// 启动3个子goroutine，传入父context
for i := 1; i <= 3; i++ {
go subTask(parentCtx, i)
}
// 等待1秒后取消父context
time.Sleep(1 * time.Second)
cancel()
// 等待子goroutine执行完毕
time.Sleep(1 * time.Second)
}
运行上述代码后，所有子goroutine都会收到父context的取消信号，在1秒后同步退出，不会出现任务继续执行的情况。这是因为所有子goroutine使用的是同一个父context，父context取消时，其Done通道关闭，所有监听该通道的goroutine都会收到通知。
嵌套goroutine中的传播机制
当goroutine中再启动新的goroutine时，context需要继续向下传递，才能保证取消信号的完整覆盖。如果某个子goroutine没有将接收到的context传递给它启动的新goroutine，那么新goroutine就无法收到取消信号，可能会出现任务泄漏的问题。
嵌套场景的错误示例
下面的代码展示了context未正确向下传递的问题：
package main
import (
"context"
"fmt"
"time"
)
func innerTask() {
// 没有接收外部传入的context，无法感知取消信号
time.Sleep(5 * time.Second)
fmt.Println("内部任务执行完成")
}
func outerTask(ctx context.Context) {
go innerTask() // 启动内部goroutine时没有传入ctx
select {
case <-ctx.Done():
fmt.Println("外部任务收到取消信号，退出")
return
}
}
func main() {
ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
go outerTask(ctx)
time.Sleep(3 * time.Second)
cancel()
time.Sleep(3 * time.Second)
}
运行上述代码会发现，即使父context在2秒后超时取消，innerTask依然会执行5秒后才结束，因为innerTask没有持有context的引用，无法感知取消信号。正确的做法是将context传递给innerTask，让内部任务也能监听取消信号。
嵌套场景的正确示例
修正后的代码如下：
package main
import (
"context"
"fmt"
"time"
)
func innerTask(ctx context.Context) {
select {
case <-ctx.Done():
fmt.Println("内部任务收到取消信号，退出")
return
case <-time.After(5 * time.Second):
fmt.Println("内部任务执行完成")
}
}
func outerTask(ctx context.Context) {
go innerTask(ctx) // 将context传递给内部goroutine
select {
case <-ctx.Done():
fmt.Println("外部任务收到取消信号，退出")
return
}
}
func main() {
ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
go outerTask(ctx)
time.Sleep(3 * time.Second)
cancel()
time.Sleep(1 * time.Second)
}
此时父context取消后，outerTask和innerTask都会同步收到取消信号，不会出现任务泄漏的问题。
context传播中的注意事项
- context应该作为函数的第一个参数传递，命名通常为ctx，不要放在结构体中存储，避免生命周期管理混乱。
- 不要传递nil context，如果不确定使用什么context，可以传递
context.TODO()，后续再根据实际情况替换。 - context的Value方法传递的数据应该是请求范围的临时数据，不要用来传递可选参数或者核心业务数据，避免代码可读性和维护性下降。
- 派生context时，要记得在不需要的时候调用cancel函数，释放相关资源，避免内存泄漏。
理解context在并发中的传播机制，能够帮助开发者更好地控制并发任务的执行流程，及时取消不需要的任务，减少资源浪费，写出更健壮的Golang并发代码。