即使通道关闭，执行例程也会陷入僵局

Question

我有一个列表，有一个从中弹出元素的函数，以及另一个“接收”弹出元素的函数。我认为在接收器之后关闭通道会关闭通道，但似乎程序在到达那里之前是死锁的。这样做的最佳方法是什么？我是否应该有另一个通道来检测弹出何时完成？

Playground link

func pop(list *[]int, c chan int) {
    if len(*list) != 0 {
        result := (*list)[0]
        *list = (*list)[1:]
        fmt.Println("about to send ", result)
        c <- result
    } else {
        return
    }
}

func receiver(c chan int) {

    result := <-c
    fmt.Println("received ", result)
}

var list = []int{1, 2, 3}

func main() {

    fmt.Println("Main")
    c := make(chan int)
    go pop(&list, c)
    go pop(&list, c)
    for len(list) > 0 {
        receiver(c)
    }
    close(c) //Dosen't seem to have any effect
    fmt.Println("done")

}

Answer 1

代码有这么多问题，看看吧。

1. 您的 pop 函数在访问切片时没有锁定，所以这就是数据竞争。
2. for len(list) > 0 {} 是一场数据竞赛，因为您正在访问列表，同时在其他 2 个 goroutine 中修改它。
3. for len(list) > 0 {} 永远不会返回，因为您的列表中有 3 项，但您只调用了两次 pop。
4. receiver(c) 错误因为 #3，它尝试从通道读取，但没有写入任何内容。

一种方法是使用一个写入器 (pop) 和多个读取器 (receiver)：

func pop(list *[]int, c chan int, done chan bool) {
    for len(*list) != 0 {
        result := (*list)[0]
        *list = (*list)[1:]
        fmt.Println("about to send ", result)
        c <- result
    }
    close(c)
    done <- true
}

func receiver(c chan int) {
    for result := range c {
        fmt.Println("received ", result)
    }
}

var list = []int{0, 1, 2, 3, 4, 5, 6, 7, 8, 9}

func main() {
    c := make(chan int)
    done := make(chan bool)
    go pop(&list, c, done)
    go receiver(c)
    go receiver(c)
    go receiver(c)
    <-done
    fmt.Println("done")
}

playground

在处理 goroutine 时总是使用 go run -race blah.go。