Go Channels - 推送到通道会停止执行

Question

我正在尝试创建一个命令行测验，用户将被问到一个又一个问题，直到他们完成最后一个问题或超时。我想使用渠道，这样我就可以学习如何正确使用它们，可以说，我遇到了障碍。CorrectAnswersCh 的想法是从 0 开始，每次正确答案后，它都会增加 1。在我将零放入通道后，测验始终停止在 quiz() 函数的第 3 行。我在下面添加了一些代码，但完整的代码在这里： https://play.golang.org/p/vzRCTc7MpIKfunc main() {    questions, err := getCsvData()    var limit = time.Duration(3)    flag.Parse()    if err != nil {        log.Fatal(err)    }    quizComplete := make(chan bool)    correctAnswersCh := make(chan int)    go quiz(quizComplete, questions, correctAnswersCh)    select {    case <-time.After(limit*time.Second):        fmt.Println("Timed Out")    }    fmt.Printf("Correct Answers: %v\n", <-correctAnswersCh)}func quiz(quizComplete chan bool, questions [][]string, correctAnswersCh chan int) {    reader := bufio.NewReader(os.Stdin)    correctAnswersCh <- 0    // execution stops here.  0 is added to correctAnswersCh, then the quiz func stops    for _, question := range questions {        fmt.Print(question[0], "= ")        answer, _ := reader.ReadString('\n')        if strings.TrimSpace(answer) == question[1] {            cA := <-correctAnswersCh            cA++            correctAnswersCh <- cA        }    }    quizComplete <- true}

Answer 1

您的correctAnswersCh频道是无缓冲的，因此在其中发送任何内容都会受到阻塞，直到有人从其中接收为止。由于您的main()函数仅在超时后接收来自它的信息，因此在此之前您的应用程序将被阻止。

一种简单的解决方法是为通道提供 1 个缓冲区：

correctAnswersCh := make(chan int, 1)

尽管这是渠道的一些奇怪用法。如果您的目的是创建并发安全计数器，请使用 aotmic 计数器，例如atomic.AddInt32()。另一种选择是在从多个 goroutine 并发访问时使用互斥体（sync.Mutex或sync.RWMutex）来保护资源（变量）。