goroutine 与 channel

goroutine 和 channel 是 Go 语言并发编程的两大基石。

goroutine

goroutine 是 Go 运行时管理的轻量级线程。使用 go 关键字即可启动：

func sayHello() {
    fmt.Println("Hello from goroutine!")
}

func main() {
    go sayHello() // 启动 goroutine
    time.Sleep(time.Second)
}

启动多个 goroutine

for i := 1; i <= 5; i++ {
    go func(id int) {
        fmt.Printf("goroutine %d 正在运行
", id)
    }(i)
}
time.Sleep(time.Second)

Channel

channel 是 goroutine 之间的通信管道：

基本用法

// 创建 channel
ch := make(chan int)

// 发送数据
go func() {
    ch <- 42
}()

// 接收数据
value := <-ch
fmt.Println(value) // 42

带缓冲的 channel

ch := make(chan string, 3)
ch <- "a"
ch <- "b"
ch <- "c"
// 不会阻塞，因为有缓冲区

使用 range 遍历 channel

ch := make(chan int)

go func() {
    for i := 0; i < 5; i++ {
        ch <- i
    }
    close(ch) // 关闭 channel
}()

for value := range ch {
    fmt.Println(value) // 0, 1, 2, 3, 4
}

select 多路复用

select 可以同时等待多个 channel 操作：

select {
case msg1 := <-ch1:
    fmt.Println("收到:", msg1)
case msg2 := <-ch2:
    fmt.Println("收到:", msg2)
case <-time.After(time.Second):
    fmt.Println("超时")
default:
    fmt.Println("没有数据")
}

同步原语

WaitGroup

var wg sync.WaitGroup

for i := 1; i <= 5; i++ {
    wg.Add(1)
    go func(id int) {
        defer wg.Done()
        fmt.Printf("任务 %d 完成
", id)
    }(i)
}

wg.Wait() // 等待所有 goroutine 完成
fmt.Println("所有任务完成")

实践建议

  1. 不要通过共享内存来通信，通过通信来共享内存
  2. 发送方负责关闭 channel
  3. 使用 sync.WaitGroup 等待 goroutine 完成
  4. 用 select 处理超时和默认情况
  5. 注意数据竞争，用 -race 标志检测