time.NewTimer 不像我预期的那样工作

Question

我有一个相当简单的程序，它应该在指定的持续时间（例如，一秒）后自行终止

代码：

package main

import (
    "fmt"
    "time"
)

func emit(wordChannel chan string, done chan bool) {
    defer close(wordChannel)

    words := []string{"The", "quick", "brown", "fox"}
    i := 0
    t := time.NewTimer(1 * time.Second)

    for {
        select {
        case wordChannel <- words[i]:
            i++
            if i == len(words) {
                i = 0
            }
        // Please ignore the following case
        case <-done:
            done <- true
            // fmt.Printf("Got done!\n")
            close(done)
            return
        case <-t.C:
            fmt.Printf("\n\nGot done!\n\n")
            return
        }
    }
}

func main() {

    mainWordChannel := make(chan string)
    // Please ignore mainDoneChannel
    mainDoneChannel := make(chan bool)

    go emit(mainWordChannel, mainDoneChannel)

    for word := range mainWordChannel {
        fmt.Printf("%s  ", word)
    }

}

我编译执行二进制，你可以看到执行here。

这显然超过 1 秒。

Go 在NewTimer 上的文档是这样写的：

func NewTimer

func NewTimer(d Duration) *Timer

NewTimer 创建一个新的 Timer，它将在至少持续时间 d 之后在其通道上发送当前时间。

有人可以帮我理解这里发生了什么吗？为什么程序在 1 秒后没有完全终止（或接近 at least）？

Answer 1

计时器按预期工作。它向通道发送一个值。 我认为阅读about select statement很有用 循环中的每次迭代都可以写入通道。 如果 > 1 通信可以继续，则无法保证哪些是。 因此，如果像这样为读取循环添加延迟：

for word := range mainWordChannel {
    fmt.Printf("%s  ", word)
    time.Sleep(time.Millisecond)
}

在这种情况下，只有从timer.C 读取才能继续。程序将结束。