Golang channel与select组合使用实战

ch1 := make(chan string)
ch2 := make(chan string)
<p>go func() {
time.Sleep(2 * time.Second)
ch1 <- "来自服务A的数据"
}()</p><p>go func() {
time.Sleep(1 * time.Second)
ch2 <- "来自服务B的数据"
}()</p><p>select {
case msg := <-ch1:
fmt.Println("收到:", msg)
case msg := <-ch2:
fmt.Println("收到:", msg)
}
// 输出：收到: 来自服务B的数据（因为更快）</p>

timeout := time.After(3 * time.Second)
ch := make(chan string)
<p>go func() {
time.Sleep(5 * time.Second) // 模拟慢操作
ch <- "处理完成"
}()</p><p>select {
case result := <-ch:
fmt.Println(result)
case <-timeout:
fmt.Println("操作超时")
}
// 输出：操作超时
</font></p></p>这个技巧广泛应用于网络请求、数据库查询等可能延迟的操作中。</p><H3>3. 非阻塞读写：default实现快速反馈</H3><p>有时我们希望尝试从 channel 读取数据，但不想阻塞。可以在 select 中使用 <strong>default</strong> 分支实现非阻塞操作。</p><font face="Courier New"><pre class="brush:php;toolbar:false;">
ch := make(chan string, 1)
ch <- "已有数据"
<p>select {
case msg := <-ch:
fmt.Println("立即读取:", msg)
default:
fmt.Println("通道为空或满，跳过")
}</p>

ctx, cancel := context.WithCancel(context.Background())
dataCh := make(chan int)
done := make(chan bool)
<p>go func() {
for {
select {
case <-ctx.Done():
fmt.Println("收到退出信号")
done <- true
return
case num := <-dataCh:
fmt.Println("处理数据:", num)
}
}
}()</p><p>dataCh <- 100
cancel() // 触发退出</p><p><-done
fmt.Println("协程已退出")</p>