上一篇建立了模块、类型和错误链。本篇把单线程程序推进为有明确退出边界的并发程序goroutine 负责执行channel 负责传递所有权context 负责取消重点不是“开更多协程”而是确保不会泄漏、阻塞或产生数据竞争。一、先区分并发、并行与数据竞争goroutine 是由 Go 运行时调度的轻量执行单元创建成本通常远低于操作系统线程但绝非免费。无限制地为每条消息启动 goroutine会把压力变成内存、连接数和下游并发洪峰。后端更常用固定 worker 数、信号量或有界队列把资源预算写进程序。并发表示多个任务的生命周期重叠并行表示某一时刻确实在多个处理器上执行。I/O 服务即使只有一个核心也能通过并发隐藏等待CPU 密集工作则受GOMAXPROCS和机器核心数制约。性能判断应来自基准和 trace而不是 goroutine 数量。数据竞争发生在多个 goroutine 并发访问同一内存至少一个访问是写且缺少同步。它不仅让结果偶尔错误还会破坏内存可见性假设。测试时执行go test -race ./...竞态检测有开销适合 CI 和预发布不应默认常驻生产。解决方式可选互斥锁、原子操作或把可变状态的所有权交给单个 goroutinechannel 并不自动消灭竞争。下面的 worker pool 有固定并发、关闭输入、等待完成和单一结果收集者。结果顺序不确定所以最终排序后输出这也是测试并发代码时避免依赖调度偶然性的技巧。packagemainimport(fmtsortsync)typeResultstruct{JobintValueint}funcworker(jobs-chanint,resultschan-Result,wg*sync.WaitGroup){deferwg.Done()forjob:rangejobs{results-Result{Job:job,Value:job*job}}}funcmain(){jobs:make(chanint)results:make(chanResult)varwg sync.WaitGroupfori:0;i3;i{wg.Add(1)goworker(jobs,results,wg)}gofunc(){forjob:1;job5;job{jobs-job}close(jobs)}()gofunc(){wg.Wait()close(results)}()all:make([]Result,0,5)forresult:rangeresults{allappend(all,result)}sort.Slice(all,func(i,jint)bool{returnall[i].Joball[j].Job})for_,result:rangeall{fmt.Printf(job%d value%d\n,result.Job,result.Value)}}运行输出job1 value1 job2 value4 job3 value9 job4 value16 job5 value25二、把 channel 当成协议而不是队列魔法无缓冲 channel 的发送和接收需要会合天然形成背压缓冲 channel 允许暂存固定数量只是推迟阻塞不会增加下游吞吐。容量应依据允许的排队延迟和内存预算而不是随手写一个大整数。队列满时必须明确策略等待、超时、丢弃还是返回过载错误。关闭 channel 表示“不会再发送新值”应由发送方或协调者执行。接收方关闭会与仍在发送的 goroutine 竞态重复关闭会 panic。读取已关闭 channel 会立刻得到零值使用value, ok : -ch区分真实零值for value : range ch会在关闭且排空后结束。channel 设为nil时收发永久阻塞可在复杂 select 中动态禁用分支但应谨慎使用。select在多个就绪通信中选择一个没有优先级保证。default会把阻塞协议变成忙轮询或丢弃协议常被误用需要等待时就让它等待需要截止时间时监听 context。time.After在循环中反复创建计时器会增加分配长期循环应复用time.Timer或time.Ticker并正确停止。context 应从入口向下传递通常作为第一个参数不存入结构体不传 nil。取消函数由创建者调用否则计时器和子节点可能存活过久。context 的 value 只放请求范围、跨 API 边界的元数据例如 trace ID配置和数据库连接应通过显式参数注入。packagemainimport(contextfmttime)funcwaitForValue(ctx context.Context,input-chanstring)(string,error){select{casevalue,ok:-input:if!ok{return,fmt.Errorf(input closed)}returnvalue,nilcase-ctx.Done():return,ctx.Err()}}funcmain(){input:make(chanstring)ctx,cancel:context.WithTimeout(context.Background(),30*time.Millisecond)defercancel()gofunc(){time.Sleep(5*time.Millisecond)input-ready}()value,err:waitForValue(ctx,input)fmt.Printf(first value%s err%v\n,value,err)timed,stop:context.WithTimeout(context.Background(),time.Millisecond)deferstop()_,errwaitForValue(timed,make(chanstring))fmt.Printf(second timeout%t\n,errcontext.DeadlineExceeded)}运行输出first valueready errnil second timeouttrue三、设计可关闭、可观测的并发流程每启动一个 goroutine都要能回答三个问题谁拥有它、它何时退出、调用方如何知道退出。后台任务常用父 context 加sync.WaitGroup收到关闭信号后先停止接收新任务再取消工作最后等待已接收任务在期限内完成。只有进程强制退出时才接受未完成工作丢失。互斥锁适合保护短小内存状态。持锁期间不要做网络 I/O、发送可能阻塞的 channel 或调用未知回调否则尾延迟和死锁风险会放大。RWMutex也不是天然更快读临界区很短或写入频繁时普通 Mutex 往往更简单。原子操作适合计数器和状态位不适合维护多个字段的不变量。生产诊断至少观察活跃 goroutine、队列深度、任务耗时、拒绝数和取消原因。goroutine 数持续增长通常意味着发送无人接收、读取永不关闭的 channel、遗漏响应体关闭或 context 未传播。可用net/http/pprof获取 goroutine profile但管理入口必须限制在内网并设置访问控制。并发正确性的核心是受控所有权与完整生命周期而不是语法上的go。下一篇会把这些模式放进标准库 HTTP 服务每个请求自带 context服务端设置超时并在终止信号到达后优雅关闭。参考来源Go 博客Go 并发模式Go 官方文档contextGo 官方文档数据竞争检测器Go Memory Model 觉得有用就点个赞 收藏方便回头查阅有疑问直接在评论区留言我看到都会回。 本文属于《Go 后端开发实战》系列持续更新关注不迷路。 文章里的代码都能直接跑。想要可直接 clone 的完整工程 配套部署脚本 / 踩坑清单评论一声或发邮件到cj2664qq.com我免费发你。如果你正好在做类似系统、或有工程化难题想找人做也欢迎邮件聊一句——我按实际情况评估能落地的就接单或出方案。评论和邮件都能直接找到我不用跳别的平台。