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