Golang并发编程怎么入门_Go语言并发学习路线详解

16次阅读

goroutine 和 channel 是 Go 并发的唯二基石,其他并发控制工具均围绕它们补足短板;新手需先写出可运行、不 panic、结果可预期的最小并发程序。

Golang并发编程怎么入门_Go语言并发学习路线详解

goroutinechannel 是 Go 并发的唯二基石,其他所有并发控制(sync.WaitGroupsync.Mutexselect)都是围绕它们补足短板的。别从“理论模型”开始,直接动手写能跑通、不 panic、结果可预期的最小并发程序——这才是真正入门。

怎么让 goroutine 不一启动就消失?

新手最常遇到的现象:go fmt.Println("hello") 运行后什么也不输出,程序秒退。这是因为主 goroutine(即 main 函数)执行完就退出了,而新启的 goroutine 还没来得及调度或打印。

  • 临时调试:用 fmt.Scanln(&input) 阻塞主 goroutine,等你按回车才退出(仅限本地测试)
  • 生产级做法:用 sync.WaitGroup 精确等待——先 wg.Add(1),goroutine 结束前调 wg.Done(),主函数末尾 wg.Wait()
  • 千万别用 time.Sleep “凑时间”:它不可靠,CPU 忙闲、GC 触发都会影响实际等待时长

channel 发送/接收卡死?先看是不是无缓冲 + 单向操作

ch := make(chan int); ch 然后就卡住?这是无缓冲 channel 的典型行为:发送操作会阻塞,直到有另一个 goroutine 在同一 channel 上执行接收 。它本质是同步点,不是“消息队列”。

  • 要异步发送(不阻塞),必须用带缓冲的 channel:ch := make(chan int, 10),缓冲满才会阻塞
  • 接收端务必在另一个 goroutine 里,否则永远等不到——go func() { 是常见模式
  • 关闭 channel 后再接收会得到零值(如 0 for int),但不会 panic;重复关闭会 panic,所以只由 sender 关闭

多个 goroutine 争抢一个变量?别急着加锁,先问能不能用 channel 拆开

比如累加计数器,看到 count++ 被多个 goroutine 并发调用,第一反应不是上 sync.Mutex,而是想:这个变量是否真的需要被所有 goroutine 共享?

立即学习go语言免费学习笔记(深入)”;

  • 如果只是收集结果(如 5 个 worker 各算一部分再汇总),用 channel 把结果“推出来”,主 goroutine 统一收——完全避免共享
  • 如果真要共享状态(如全局配置热更新),再用 sync.RWMutex(读多写少时比普通 Mutex 更高效)
  • 记住:sync.Mutex 只保护临界区,不解决逻辑竞态。比如“检查再设置”这种操作,即使加锁也需用 sync.Once 或 CAS(atomic 包)

worker 模式怎么写才不漏任务、不 panic?

典型场景:一批 job 分发给固定数量的 worker 并发处理。容易出错的是 channel 关闭时机和接收循环写法。

  • 必须由 sender(通常是 main)负责 close(jobs),且要在所有 job 发送完毕后——不能边发边关
  • worker 用 for j := range jobs 安全遍历,channel 关闭后自动退出循环,无需额外判断
  • results channel 如果不带缓冲,又没及时接收,worker 会卡在 results ;要么加缓冲,要么确保主 goroutine 在 worker 运行时持续
jobs := make(chan int, 5) results := make(chan int, 5) // 缓冲防阻塞 

// 启动 worker for w := 1; w <= 3; w++ { go func(id int) { for j := range jobs { results <- j *>

// 发送任务 for j := 1; j <= 5; j++ { jobs <- j } close(jobs)>

// 收结果(顺序不保证) for i := 0; i < 5; i++ { fmt.Println(<-results) }

真正难的从来不是语法,而是判断“这里该不该并发”“数据流该走 channel 还是锁”“谁负责关闭 channel”。这些没法靠背文档解决,只能在一个个真实任务里反复试错、观察 goroutine profile、看 go tool trace 输出——入门之后,下一步就是让并发可观察、可验证。

text=ZqhQzanResources