Goroutine是Go并发核心，通过go关键字启动轻量级线程，配合WaitGroup同步、channel通信、select多路复用及Mutex保护共享资源，实现高效安全并发。
在Golang中，goroutine 是实现并发的核心机制。它是一种轻量级线程，由Go运行时管理，启动成本低，适合高并发场景。下面介绍几种基础且实用的goroutine并发执行方法。
1. 启动基本goroutine
使用 go 关键字即可启动一个goroutine，函数会异步执行。
示例：package main
<p>import (
"fmt"
"time"
)</p><p>func sayHello() {
fmt.Println("Hello from goroutine")
}</p><p>func main() {
go sayHello()
time.Sleep(100 * time.Millisecond) // 等待goroutine执行
fmt.Println("Main function")
}
注意：主函数退出后，所有goroutine都会终止，因此需要适当同步（如Sleep或WaitGroup）来确保执行完成。
2. 使用sync.WaitGroup等待多个goroutine
当需要等待一组goroutine完成时，sync.WaitGroup 是最常用的同步工具。
立即学习“go语言免费学习笔记（深入）”；
示例：package main
<p>import (
"fmt"
"sync"
)</p><p>func worker(id int, wg *sync.WaitGroup) {
defer wg.Done()
fmt.Printf("Worker %d starting\n", id)
// 模拟任务耗时
fmt.Printf("Worker %d done\n", id)
}</p><p>func main() {
var wg sync.WaitGroup</p><pre class="brush:php;toolbar:false;">for i := 1; i <= 3; i++ {
wg.Add(1)
go worker(i, &wg)
}
wg.Wait() // 阻塞直到所有worker调用Done()
fmt.Println("All workers finished")}
3. 使用channel进行goroutine通信
Go提倡“通过通信共享内存”，channel 是goroutine之间安全传递数据的方式。
示例：通过channel接收结果
package main
<p>import "fmt"</p><p>func fetchData(ch chan string) {
ch <- "data from goroutine"
}</p><p>func main() {
ch := make(chan string)
go fetchData(ch)
result := <-ch // 从channel读取数据
fmt.Println(result)
}
无缓冲channel会阻塞发送和接收，直到双方就绪；有缓冲channel可缓解短暂速度差异。
4. 使用select处理多个channel
当需要从多个channel中接收数据时，select 可以实现多路复用。
示例：package main
<p>import (
"fmt"
"time"
)</p><p>func sendMsg(ch chan string, msg string, delay time.Duration) {
time.Sleep(delay)
ch <- msg
}</p><p>func main() {
ch1 := make(chan string)
ch2 := make(chan string)</p><pre class="brush:php;toolbar:false;">go sendMsg(ch1, "msg from 1", 100*time.Millisecond)
go sendMsg(ch2, "msg from 2", 200*time.Millisecond)
for i := 0; i < 2; i++ {
select {
case msg := <-ch1:
fmt.Println(msg)
case msg := <-ch2:
fmt.Println(msg)
}
}}
5. 避免常见并发问题
goroutine虽简单，但共享变量可能引发竞态条件。建议：
- 避免多个goroutine直接读写同一变量
- 使用channel传递数据而非共享内存
- 必要时使用 sync.Mutex 保护临界区
package main
<p>import (
"sync"
)</p><p>var counter int
var mu sync.Mutex</p><p>func increment(wg *sync.WaitGroup) {
defer wg.Done()
mu.Lock()
counter++
mu.Unlock()
}
基本上就这些。掌握这些基础方法，就能在Go中高效、安全地使用goroutine实现并发。关键是理解goroutine生命周期、同步机制和channel的使用场景。
