Go语言中select使用详解

select {
case val := <-ch1:
    // ch1 可读时执行
case ch2 <- 100:
    // ch2 可写时执行
default:
    // 所有 channel 都阻塞时执行（可选）
}

select {
case msg1 := <-ch1:
    fmt.Println("收到 ch1：", msg1)
case msg2 := <-ch2:
    fmt.Println("收到 ch2：", msg2)
}

select {
case msg := <-ch:
    fmt.Println("收到：", msg)
case <-time.After(2 * time.Second):
    fmt.Println("超时")
}

select {
case ch <- data:
    fmt.Println("发送成功")
default:
    fmt.Println("channel 满，放弃发送")
}

select {
case v, ok := <-ch:
    if !ok {
        fmt.Println("通道关闭")
    } else {
        fmt.Println("收到：", v)
    }
}

func producer(ch chan int) {
    for i := 0; i < 5; i++ {
        ch <- i
    }
    close(ch)
}
​
func consumer(ch chan int, done chan struct{}) {
    for {
        select {
        case val, ok := <-ch:
            if !ok {
                done <- struct{}{}
                return
            }
            fmt.Println("消费：", val)
        }
    }
}

for {
    select {
    case msg := <-ch:
        fmt.Println("收到：", msg)
    case <-time.After(5 * time.Second):
        fmt.Println("超时退出")
        return
    }
}

ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
defer cancel()
​
ch := make(chan int)
​
go func() {
    time.Sleep(2 * time.Second)
    ch <- 42
}()
​
select {
case <-ctx.Done():
    fmt.Println("操作取消/超时：", ctx.Err())
case val := <-ch:
    fmt.Println("接收到数据：", val)
}