Golang通过go关键字启动goroutine实现并发,配合channel进行通信,使用WaitGroup等待执行完成,避免竞态与泄漏。

在Golang中实现goroutine并发执行非常直接,Go语言通过轻量级线程(goroutine)和通道(channel)提供了强大的并发支持。你只需要在函数调用前加上 go 关键字,就能启动一个新goroutine并发运行。
启动基本的goroutine
每个goroutine是一个独立执行的函数,由Go运行时调度管理。它比操作系统线程更轻量,可以轻松创建成千上万个。
示例:package main
<p>import (
"fmt"
"time"
)</p><p>func sayHello() {
fmt.Println("Hello from goroutine")
}</p><p>func main() {
go sayHello() // 启动一个goroutine
time.Sleep(100 * time.Millisecond) // 等待goroutine执行完成
fmt.Println("Main function ends")
}
如果不加 time.Sleep,主程序可能在goroutine执行前就退出了,导致看不到输出。
使用channel进行goroutine通信
多个goroutine之间不能直接共享内存通信,推荐使用channel传递数据,避免竞态条件。
立即学习“go语言免费学习笔记(深入)”;
示例:带缓冲的channel控制并发package main
<p>import "fmt"</p><p>func worker(id int, jobs <-chan int, results chan<- int) {
for job := range jobs {
fmt.Printf("Worker %d processing job %d\n", id, job)
results <- job * 2
}
}</p><p>func main() {
jobs := make(chan int, 5)
results := make(chan int, 5)</p><pre class="brush:php;toolbar:false;">// 启动3个worker goroutine
for w := 1; w <= 3; w++ {
go worker(w, jobs, results)
}
// 发送5个任务
for j := 1; j <= 5; j++ {
jobs <- j
}
close(jobs)
// 收集结果
for a := 1; a <= 5; a++ {
<-results
}}
使用sync.WaitGroup等待所有goroutine完成
当不需要返回值时,可以用 sync.WaitGroup 来等待一组goroutine执行完毕。
示例:package main
<p>import (
"fmt"
"sync"
)</p><p>func task(id int, wg *sync.WaitGroup) {
defer wg.Done()
fmt.Printf("Task %d is done\n", id)
}</p><p>func main() {
var wg sync.WaitGroup</p><pre class="brush:php;toolbar:false;">for i := 1; i <= 5; i++ {
wg.Add(1)
go task(i, &wg)
}
wg.Wait() // 阻塞直到所有task调用Done()
fmt.Println("All tasks completed")}
基本上就这些。合理使用go关键字、channel和WaitGroup,就能高效安全地实现并发。注意避免常见问题如goroutine泄漏、死锁和竞态条件。配合context包还能实现超时控制和取消机制。不复杂但容易忽略细节。










