goroutine是Go运行时管理的轻量级线程,通过go关键字启动,实现高效并发;2. 多个goroutine间应通过channel通信而非共享内存,channel用make创建,使用<-操作符发送和接收数据。
Go语言通过简洁高效的机制支持并发编程,其中最核心的特性之一就是goroutine。它让开发者可以轻松编写并发程序,充分利用多核处理器性能。理解goroutine的基本用法和并发控制方式,是掌握Go并发编程的第一步。
什么是Goroutine
goroutine 是 Go 运行时管理的轻量级线程。由 Go runtime 调度,开销远小于操作系统线程。启动一个 goroutine 只需在函数调用前加上 go 关键字。
例如:
func sayHello() {
fmt.Println(“Hello from goroutine”)
}
func main() {
go sayHello()
time.Sleep(100 * time.Millisecond) // 等待 goroutine 执行完毕
fmt.Println(“Main function”)
}
上面代码中,go sayHello() 启动了一个新的 goroutine 并发执行。注意:main 函数不会等待 goroutine 自动完成,因此需要使用 time.Sleep 或其他同步机制防止主程序提前退出。
立即进入“豆包AI人工智官网入口”;
立即学习“豆包AI人工智能在线问答入口”;
使用 channel 进行 goroutine 通信
多个 goroutine 之间不应共享内存通信,而应通过 channel 传递数据。channel 是 Go 中用于在 goroutine 之间安全传递值的管道。
创建 channel 使用 make:
ch := make(chan string)
向 channel 发送数据用 <- 操作符:
ch
从 channel 接收数据:
value :=
示例:主 goroutine 启动另一个 goroutine 处理任务并返回结果:
func worker(ch chan string) {
ch }
func main() {
ch := make(chan string)
go worker(ch)
result := <-ch
fmt.Println(result)
}
这种方式避免了竞态条件,保证了数据安全传递。
使用 sync.WaitGroup 等待多个 goroutine
当需要等待一组 goroutine 完成时,sync.WaitGroup 是常用工具。它通过计数器控制等待逻辑。
主要方法:
- Add(n):增加计数器
- Done():计数器减 1
- Wait():阻塞直到计数器为 0
示例:
func doTask(id int, wg *sync.WaitGroup) {
defer wg.Done()
fmt.Printf(“Task %d is runningn”, id)
}
func main() {
var wg sync.WaitGroup
for i := 0; i < 5; i++ {
wg.Add(1)
go doTask(i, &wg)
}
wg.Wait()
fmt.Println(“All tasks completed”)
}
每个 goroutine 执行完调用 Done(),主函数 Wait() 会一直阻塞直到所有任务结束。
避免常见并发问题
尽管 goroutine 使用简单,但不注意仍会导致问题:
- 主 goroutine 提前退出导致子 goroutine 未执行
- 多个 goroutine 同时访问共享变量引发竞态
- channel 死锁(如双向阻塞)
建议:
- 使用 -race 参数运行程序检测竞态:go run -race main.go
- 避免直接共享变量,优先使用 channel 通信
- 关闭不再使用的 channel,防止接收端永久阻塞
基本上就这些。goroutine + channel + WaitGroup 构成了 Go 并发编程的基础组合。掌握它们的配合使用,就能写出清晰、安全、高效的并发程序。不复杂但容易忽略细节,多写多练才能熟练。
go golang 操作系统 处理器 go语言 ai 并发编程 同步机制 golang String 线程 Go语言 并发 channel function