[!info] related notes

• 所属 MOC：并发 MOC · 学习路线
• 前置概念：channel、goroutine
• 后续概念：context、取消传播、happens-before
• 容易混淆：switch、忙轮询、time.Sleep 当超时

Go select

这个概念为什么会出现

一个 goroutine 往往同时关心多条“通信事件”，而不是只等一个 channel：

• 结果 channel 有没有值？
• 取消信号到了没有？
• 超时是否触发？
• 另一条旁路命令是否到达？

若用嵌套接收或忙轮询，代码会迅速变成不可读的阻塞迷宫。select 把多路 channel 操作收成一次选择：哪些 case 能立刻进行通信，就从中挑一个执行。

它是 Go 并发控制流的“交叉路口”，不是普通 switch。

[!abstract] 一句话理解 select 等待一组 channel 发送/接收操作中至少一个就绪；若多个同时就绪则伪随机选一个；带 default 则非阻塞；把 case 的 channel 设为 nil 可动态禁用该分支。

最小可运行示例

先把示例放进业务场景，再看代码：

场景：支付回调处理——结果、请求取消、兜底超时三选一

支付服务调银行渠道后，handler 同时盯三件事：

1. 结果分支被选中 → 处理渠道结果
2. 取消分支被选中 → 停止等待，按业务协议收尾
3. 本地超时分支被选中 → 返回等待超时

这只演示等待结果，不实现支付落单：取消等待不能撤销渠道已经发生的扣款或保证后续写入绝不发生。

select 从选择时已就绪的分支中挑一个；若处理不及时而多个分支都就绪，不保证选最早就绪的那个。 它不是 switch 布尔条件，而是多路通信选择。

package main

import (
	"context"
	"fmt"
	"time"
)

func main() {
	// 模拟 HTTP 请求级 ctx：最多等 80ms（客户端超时/网关预算）。
	ctx, cancel := context.WithTimeout(context.Background(), 80*time.Millisecond)
	defer cancel()

	// 渠道结果通道：缓冲 1，避免发送方在无人接收时额外复杂化（演示用）。
	result := make(chan string, 1)

	// 后台：模拟银行渠道 30ms 后返回成功。
	go func() {
		time.Sleep(30 * time.Millisecond)
		result <- "payment-ok"
	}()

	// 一次 select：只挑一个就绪的 case 执行。
	// 持续监听事件应写成 for { select { ... } }。
	select {
	case v := <-result:
		// 结果分支被选中；不代表取消此时尚未发生。
		fmt.Println("got", v)
	case <-ctx.Done():
		// 请求预算先耗尽或上游取消。
		fmt.Println("cancelled:", ctx.Err())
	case <-time.After(200 * time.Millisecond):
		// 兜底：比 ctx 更晚的本地超时（本参数下通常轮不到）。
		// 每次进入 select 都会创建 timer；本例只等待一次。
		fmt.Println("timeout via After")
	}
}

建议运行：

go run .

通常输出（30ms < 80ms；调度延迟可能使多个分支同时就绪）：

got payment-ok

若把渠道 Sleep 改成 120 * time.Millisecond，通常会变成：

cancelled: context deadline exceeded

结合场景再看三个关注点

1. case 必须是 channel 发送/接收
   不是 case err != nil 这种布尔分支。

2. 多 case 同时就绪时伪随机选一个
   不要把书写顺序当优先级。预检查可偏向当时已就绪的信号，但检查后仍有竞争窗口。

3. 一次 select 只提交一次
   worker 常驻监听要包 for；本例是“等一次支付结果”的单次选择。

核心概念与准确模型

语法形态

select {
case <-ch1:
    // 接收
case v, ok := <-ch2:
    // 接收并判断是否关闭
case ch3 <- x:
    // 发送
default:
    // 可选：没有任何 case 可进行时立即执行
}

规范：Select statements

求值与选择规则

进入 select 时：

1. 按源码顺序、各求值一次：每个 case 的 channel 操作数与发送值；接收赋值左侧的表达式此时不求值。
2. 若有一个或多个通信可进行：从就绪集合中均匀伪随机选一个执行。
3. 若没有可进行的通信：
   • 有 default → 执行 default（非阻塞）
   • 无 default → 阻塞，直到某个 case 可进行
4. 选中 case 后执行通信；若有接收赋值，求值左侧并赋值，再运行 case 体。

这些预先求值的表达式若阻塞，default 或 ctx.Done 也无法让它们跳过；nil 发送 case 的发送值仍会求值。

伪随机选择没有书写顺序优先级。嵌套 select 可以实现一次预检查或再次检查，不能原子地保证“取消一发生就绝不发送/提交”；严格提交边界需要由业务状态和同步协议保证。

default：非阻塞探测

select {
case v := <-ch:
    use(v)
default:
    // ch 此刻不可接收，立即继续
}

用途：

• 尝试发送/接收但不想卡住
• 实现“有就取，没有就跳过”的 drain
• 非阻塞状态机步进

滥用 default 会变成忙轮询，应配合 time.Ticker 或阻塞 select。

nil channel：动态禁用 case

对 nil channel：

• 发送永久阻塞
• 接收永久阻塞

因此：

var ch <-chan int = maybe
if disable {
    ch = nil
}
select {
case v := <-ch: // disable 时此 case 永不选中
    ...
case <-ctx.Done():
    return ctx.Err()
}

这是 fan-in、阶段性关闭某路输入的惯用技巧，但必须保留至少一条可退出路径，否则可能死锁。

超时模式

一次性等待：

select {
case v := <-ch:
    return v, nil
case <-time.After(time.Second):
    return zero, errTimeout
}

循环里的计时器： 每轮 time.After 都会重新开始等待 d，表达空闲超时；持续收到数据可能一直推迟超时。整个操作的总时限应在循环外建 Timer 或 context deadline。频繁分配是否值得复用 Timer，应测量后决定。

Go 1.23 的新计时器语义允许 GC 回收不再被引用、尚未到期的 timer；旧语义下未停止的 timer 要等到期才可回收。新语义默认要求主模块 go.mod 声明 go 1.23 或更高；GODEBUG=asynctimerchan=1 可强制旧语义，=0 可强制新语义（本次核对 Go 1.26.8）。

一次等待也可用显式 Timer：

t := time.NewTimer(d)
defer t.Stop()
select {
case <-ch:
case <-t.C:
}
// 此例不复用 timer；函数退出时由 defer Stop。

新语义下，基于 channel 的 Timer 在 Stop/Reset 返回后不会再交付旧配置的值，无需旧式排空。兼容旧语义且要复用时，需协调 Stop、接收和 Reset；不要对已被消费的 timer 盲目阻塞读取。具体条件见 time.Timer 文档。

与 context 组合

select {
case res := <-resultCh:
    return res, nil
case <-ctx.Done():
    return zero, ctx.Err()
}

这是结果与取消/截止时间的竞争；若 resultCh 可以关闭且关闭不代表成功，要检查 ok。Done 就绪只使取消分支可选，不会替你取消生产者或等待其退出。详见 context。

空 select

select {} // 永久阻塞当前 goroutine

有时用于“只跑后台任务的 main”，但生产代码更常见的是显式 Wait / 信号量退出。

与 switch 的本质区别

	switch	select
分支条件	表达式/类型	channel 发送或接收
多分支同时真	顺序匹配（或 fallthrough）	就绪集合中伪随机
默认	default 无匹配时	default 无通信可进行时
阻塞	不阻塞	无 default 时可阻塞

设计动机

1. 把并发控制流写扁平
   超时、取消、结果在同一层表达。
2. 与 channel 所有权模型配套
   通信即同步点；多路等待仍保持 happens-before 语义。
3. 避免“先等谁”的隐式优先级 bug
   伪随机迫使你在需要优先级时显式设计。

边界情况与反直觉行为

1. 只执行一个 case
   即使多个就绪，一轮 select 只走一个分支。
2. case 求值副作用
   发送表达式会在进入 select 时求值，即便该 case 最终未被选中。
3. 已关闭 channel 的接收永远就绪
   会读到剩余缓冲或零值；ok=false 后若仍 case <-ch 会反复就绪并消耗 CPU；关闭后应 ch = nil 或退出循环。
4. 向已关闭 channel 发送
   在 select 中若该发送 case 被选中 → panic。
5. 无 default 且所有 case 的 channel 都是 nil
   永久阻塞。
6. 公平性
   规范保证的是就绪时的伪随机选择，不是跨时间片的严格公平调度保证。

常见误区

[!warning] 常见误区：把 select 当 if-else 优先级队列 错误：以为写在前面的 case 优先。
正确：多就绪时伪随机；预检查只能表达检查时刻的偏好，不能消除检查后信号到达的竞争。

[!warning] 常见误区：循环里每次 time.After 每轮创建会重置等待起点并增加分配；只有旧语义才有未到期 timer 不能提前回收的问题。总时限放循环外，空闲时限按需重置；复用时遵循目标版本的 Stop/Reset 契约。

[!warning] 常见误区：关闭后仍 range-select 同一 channel 错误：已关闭 channel 接收总是就绪，变成热循环。
正确：检测到 !ok 后退出或 ch = nil。

[!warning] 常见误区：用 default 当“超时” 错误：default 只表示“此刻不能通信”，不是“等一会儿”。
正确：超时用 timer / ctx 的 Done。

工程实践

1. 需要可取消的结果等待时，用 select 同时监听结果和 Done；避免先阻塞在结果上。
2. fan-in 用 for + select，输入结束则置 nil。
3. 可取消发送用 select；下游提前退出时必须实际触发取消，上游也要把所有阻塞点纳入退出协议。
4. 不要用 sleep 模拟就绪；用 channel/timer/ctx。
5. 测试 用短 timeout + 可控 fake clock 思路（或注入 channel），避免 flaky sleep。
6. 可读性 case 体保持短；复杂逻辑抽函数。

可验证实验

1. 两个缓冲 channel 都有值，循环 select 多次，观察分支分布是否大致均匀。
2. 无 default 时对空无缓冲 channel select → 阻塞/死锁。
3. 有 default 时立即打印 “idle”。
4. ch = nil 后对应 case 不再被选中。
5. close(ch) 后，该接收分支总是就绪；若还有别的就绪分支，不保证选中它。
6. 对比循环内 After 的空闲时限和循环外 Timer 的总时限。分配成本用 benchmark 的 -benchmem/内存 profile 观察；timer 数量不能用 runtime.NumGoroutine 推断。

本节总结

• 本质：多路 channel 通信上的一次选择。
• 关键规则：就绪伪随机、default 非阻塞、nil 禁用、关闭接收恒就绪。
• 工程主线：结果 + ctx.Done + 超时。
• 最易错：误认为有优先级、混淆总时限与空闲时限、忽略 timer 版本语义、关闭后热循环。
• 下一步：context 与 sync 的取舍。

自测题

概念题

1. 多个 case 同时就绪时，select 如何选择？
2. default 与 time.After 的语义差别是什么？
3. 为什么把 channel 设为 nil 可以禁用 case？

代码推理题

ch := make(chan int)
close(ch)
for i := 0; i < 3; i++ {
    select {
    case v, ok := <-ch:
        fmt.Println(v, ok)
    default:
        fmt.Println("default")
    }
}

会打印什么？为什么 default 不会执行？

工程思考题

worker 从 jobs 取任务，同时必须响应 ctx 取消；jobs 关闭表示不再有新任务。如何写 for/select 才不会在关闭后空转？

参考答案

展开

1. 从就绪 case 中伪随机选一个。
2. default：此刻不能通信就立刻走；time.After：等待一段时间后 timer channel 就绪。
3. nil channel 上的发送/接收永不就绪，故该 case 不会被选中。
   代码：该例唯一通信分支始终就绪，因此必定连续打印 0 false 三遍，不进入 default。 工程：单输入 worker 在 ok=false 时直接 return；多输入 fan-in 可将已关闭输入设为 nil，全部输入结束后退出。select 内的无标签 break 只退出 select，不会退出外层 for。

延伸阅读与资料来源

资料	类型	支撑
Spec — Select statements	规范	求值与选择语义
Spec — Channel types	规范	nil/关闭与通信
Effective Go — Select	文档	用法
Package time	标准库	Timer / After
Go 1.23 Timer Channel Changes	官方 Wiki	GC、Stop/Reset 与版本切换
Package context	标准库	Done / 取消

---

笔记元信息

• 建议文件名：go-select.md
• 所属阶段：阶段四
• 本篇状态：已深化
• 建议下一篇：Go context