go - 选择忽略慢的情况？

Question

我在多个案例中使用了这样的 select:

for {
    select {
    case data:= <- highFreqChan:
        // do something:
    case <- time.After(time.Second * 5):
        // send some heartbeat like data...
    }
}

我发现，如果highFreqChan获取到大量数据，heartbeat case不会进入，当停止向highFreqChan发送数据时，heartbeat case又活了，怎么办让它在 highFreqChan 还在工作的时候一直进入心跳状态？

Answer 1

您正在运行 time.After 作为选择条件的一部分，这意味着它在达到选择时被评估...这意味着它将在 5 秒后过期 已达到选择。因此，只有当 highFreqChan 连续 5 秒没有任何数据时，您才会进入这种情况。

如果您想每 5 秒执行一次操作，请使用 time.Ticker相反，像这样:

heartbeat := time.NewTicker(5 * time.Second)
defer heartbeat.Stop()
for {
    select {
    case data:= <- highFreqChan:
        // do something:
    case <- heartbeat.C:
        // send some heartbeat like data...
    }
}