当前位置：首页 > news >正文

Go 语言并发核心：深入理解 Goroutine

news 2026/6/26 18:23:23

1. 什么是 Goroutine？

Goroutine 是 Go 语言并发编程的核心概念，可以理解为一种轻量级的线程。与操作系统线程（OS Thread）相比，Goroutine 的创建和切换成本极低，这使得 Go 程序能够轻松创建成千上万个并发执行单元。

Goroutine 的主要特点：

轻量级：初始栈大小仅 2KB（可动态增长），远小于线程的 MB 级栈
低成本创建：创建开销极小，可轻松创建数十万个 Goroutine
由 Go 运行时调度：不直接映射到操作系统线程，由 Go 自己的调度器管理
通信通过 Channel：遵循 “不要通过共享内存来通信，而要通过通信来共享内存” 的原则

2. Goroutine 的基本用法

2.1 启动 Goroutine

使用go关键字即可启动一个 Goroutine：

packagemainimport("fmt""time")funcsayHello(){fmt.Println("Hello from Goroutine!")}funcmain(){// 启动一个 GoroutinegosayHello()// 主 Goroutine 继续执行fmt.Println("Hello from main Goroutine!")// 等待一下，让 sayHello 有机会执行time.Sleep(100*time.Millisecond)}

2.2 匿名函数 Goroutine

也可以直接使用匿名函数启动 Goroutine：

packagemainimport"fmt"funcmain(){// 使用匿名函数启动 Goroutinegofunc(namestring){fmt.Printf("Hello, %s!\n",name)}("Gopher")// 等待 Goroutine 执行time.Sleep(50*time.Millisecond)}

3. Goroutine 与主程序同步

由于 Goroutine 是异步执行的，我们需要确保主程序等待 Goroutine 完成。常用的同步方式有：

3.1 使用 sync.WaitGroup

packagemainimport("fmt""sync")funcworker(idint,wg*sync.WaitGroup){deferwg.Done()// 完成后通知 WaitGroupfmt.Printf("Worker %d starting\n",id)// 模拟工作fmt.Printf("Worker %d done\n",id)}funcmain(){varwg sync.WaitGroupfori:=1;i<=5;i++{wg.Add(1)// 增加等待计数goworker(i,&wg)}wg.Wait()// 等待所有 Goroutine 完成fmt.Println("All workers completed")}

3.2 使用 Channel 同步

packagemainimport"fmt"funcworker(idint,donechanbool){fmt.Printf("Worker %d working...\n",id)done<-true// 发送完成信号}funcmain(){done:=make(chanbool,3)fori:=1;i<=3;i++{goworker(i,done)}// 等待所有 worker 完成fori:=1;i<=3;i++{<-done}fmt.Println("All workers completed")}

4. Goroutine 调度原理

4.1 G-M-P 模型

Go 的调度器采用 G-M-P 模型：

G (Goroutine)：表示一个 Goroutine，包含栈、程序计数器等信息
M (Machine)：代表操作系统线程，真正执行代码的实体
P (Processor)：逻辑处理器，管理 Goroutine 队列

4.2 调度特点

工作窃取（Work Stealing）：空闲的 P 会从其他 P 的队列中"窃取" Goroutine
抢占式调度：Go 1.14 开始支持基于信号的抢占，防止 Goroutine 长时间占用 CPU
网络轮询器：独立的网络 I/O 处理，避免阻塞 Goroutine

5. 常见模式与最佳实践

5.1 生产者-消费者模式

packagemainimport("fmt""time")funcproducer(chchan<-int){fori:=0;i<5;i++{ch<-i fmt.Printf("Produced: %d\n",i)time.Sleep(100*time.Millisecond)}close(ch)}funcconsumer(idint,ch<-chanint){foritem:=rangech{fmt.Printf("Consumer %d received: %d\n",id,item)time.Sleep(200*time.Millisecond)}}funcmain(){ch:=make(chanint,3)// 启动生产者goproducer(ch)// 启动多个消费者fori:=1;i<=3;i++{goconsumer(i,ch)}time.Sleep(2*time.Second)}

5.2 扇出/扇入模式

packagemainimport("fmt""sync")// 扇出：一个输入 channel，多个 Goroutine 处理funcfanOut(input<-chanint,numWorkersint)[]<-chanint{outputs:=make([]<-chanint,numWorkers)fori:=0;i<numWorkers;i++{ch:=make(chanint)outputs[i]=chgofunc(workerIDint,outchan<-int){forval:=rangeinput{out<-val*workerID}close(out)}(i+1,ch)}returnoutputs}// 扇入：多个 channel 合并为一个funcfanIn(channels...<-chanint)<-chanint{varwg sync.WaitGroup out:=make(chanint)for_,ch:=rangechannels{wg.Add(1)gofunc(c<-chanint){deferwg.Done()forval:=rangec{out<-val}}(ch)}gofunc(){wg.Wait()close(out)}()returnout}

6. 注意事项与常见陷阱

6.1 Goroutine 泄漏

忘记关闭 channel 或 Goroutine 无法退出会导致泄漏：

// ❌ 错误示例：Goroutine 泄漏funcleakyFunction(){ch:=make(chanint)gofunc(){// 这个 Goroutine 永远不会退出for{select{case<-ch:// 没有退出逻辑}}}()}// ✅ 正确做法：使用 context 控制生命周期funcproperFunction(ctx context.Context){ch:=make(chanint)gofunc(){for{select{case<-ctx.Done():return// 可以正常退出caseval:=<-ch:fmt.Println(val)}}}()}

6.2 数据竞争

多个 Goroutine 同时访问共享数据可能导致数据竞争：

// ❌ 存在数据竞争varcounterintfori:=0;i<1000;i++{gofunc(){counter++// 数据竞争！}()}// ✅ 使用 sync.Mutex 保护var(counterintmu sync.Mutex)fori:=0;i<1000;i++{gofunc(){mu.Lock()counter++mu.Unlock()}()}// ✅ 更好的做法：使用 sync/atomicvarcounterint32fori:=0;i<1000;i++{gofunc(){atomic.AddInt32(&counter,1)}()}