带default分支的select循环中为何ticker.C未按预期触发？

问题场景 #

你编写了一段Go代码，希望尽可能快地发送消息并每秒生成进度报告，但实际运行中定时器报告并非每秒打印，甚至超时触发晚了28秒。代码如下：

messageGenerator := MessageGenerator{}

reportTicker := time.NewTicker(1 * time.Second)
defer reportTicker.Stop()

messagesSinceLastReport := 0

durationTimeout := time.After(duration)

for {
    select {
    case <-reportTicker.C:
        slog.Info("Sent messages during the last second", "amount", messagesSinceLastReport, "timestamp", time.Now().Unix())
        messagesSinceLastReport = 0
    case <-durationTimeout:
        return
    default:
        messageGenerator.writeNext(w)
        messagesSinceLastReport++
    }
}

问题根源 #

这不是reportTicker.C优先级低的问题，而是**select中default分支的特性导致定时器事件被“饿死”**：

• Go的select对所有case是公平调度的，不存在优先级高低。
• 当select包含default分支时，只要没有任何case的通道就绪，就会立刻执行default分支，不会阻塞等待事件。
• 你的messageGenerator.writeNext(w)执行速度极快，导致select循环一直重复执行default分支，根本没有机会去检查reportTicker.C和durationTimeout的就绪状态。定时器的事件虽然已经触发，但当前goroutine被持续占用在发送消息的循环中，无法处理这些通道消息，最终导致报告延迟、超时晚触发。

解决方法 #

方法1：分离发送与监控goroutine（推荐） #

将发送消息的逻辑放到单独的goroutine中，主goroutine专门处理定时器和超时，确保监控逻辑能及时执行：

messageGenerator := MessageGenerator{}

reportTicker := time.NewTicker(1 * time.Second)
defer reportTicker.Stop()

// 用原子变量保证多goroutine下的计数安全
var messagesSinceLastReport int32

durationTimeout := time.After(duration)

// 启动发送消息的goroutine
go func() {
    for {
        select {
        case <-durationTimeout:
            return
        default:
            messageGenerator.writeNext(w)
            atomic.AddInt32(&messagesSinceLastReport, 1)
        }
    }
}()

// 主goroutine处理定时器报告和超时
for {
    select {
    case <-reportTicker.C:
        // 原子交换重置计数
        count := atomic.SwapInt32(&messagesSinceLastReport, 0)
        slog.Info("Sent messages during the last second", "amount", count, "timestamp", time.Now().Unix())
    case <-durationTimeout:
        return
    }
}

方法2：给default分支添加短暂休眠（权宜之计） #

如果不想拆分goroutine，可以在default分支末尾添加极短的休眠，让select有机会检查定时器事件，但这种方法会影响发送效率，休眠时间也难以精准控制：

// 原循环中default分支修改为：
default:
    messageGenerator.writeNext(w)
    messagesSinceLastReport++
    // 给select机会处理其他case
    time.Sleep(1 * time.Microsecond)

内容的提问来源于stack exchange，提问作者vstollen