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 或其他同步机制防止主程序提前退出。
立即学习“go语言免费学习笔记(深入)”;
使用 channel 进行 goroutine 通信
多个 goroutine 之间不应共享内存通信,而应通过 channel 传递数据。channel 是 Go 中用于在 goroutine 之间安全传递值的管道。
创建 channel 使用 make:
ch := make(chan string)向 channel 发送数据用 操作符:
ch从 channel 接收数据:
使用 ImageMagick 的 convert 和 mogrify 命令进行批量图像处理,支持调整大小、裁剪、水印和格式转换。与 libvips 集成以实现高性能缩略图生成。
示例:主 goroutine 启动另一个 goroutine 处理任务并返回结果:
func worker(ch chan string) {ch }
func main() {
ch := make(chan string)
go worker(ch)
result :=
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 running\n", id)
}
func main() {
var wg sync.WaitGroup
for i := 0; 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 并发编程的基础组合。掌握它们的配合使用,就能写出清晰、安全、高效的并发程序。不复杂但容易忽略细节,多写多练才能熟练。


















