使用带有选择的通道时的 Goroutine 死锁

Question

我试图重写一个没有使用selector 的工作程序WaitGroup，以便它可以实现selectand WaitGroup，但是我遇到了一个问题，我找不到解决方案。似乎是 goroutine deadlock 发生了，因为Manager函数没有从 writer channel 取数据，所以 channel 被阻止发送/接收，程序被锁住。原来的工作Manager功能，没有select：func Manager(list *[]Request, writerChan <-chan int) {    ageIn, writersOpen := <-writerChan    for {        if writersOpen { // if writers channel is open            Add(list, Request{Value: ageIn, Count: 1}) // putting new object to list            ageIn, writersOpen = <-writerChan          // receiving new player from writer channe;        } else {            break        }    }}所以我有一个工作程序，但需要实施，WaitGroup并且select有更新的代码：具有实现的更新Manager功能select：func Manager(list *[]Request, writerChan <-chan int) {    defer waitGroup.Done()    for {        select {        case ageIn := <-writerChan:            Add(list, Request{Value: ageIn, Count: 1}) // add player to list        default:            break        }    }}更新后的Main功能与WaitGroup实施：var waitGroup sync.WaitGroupfunc main() {    list := ParallelList{List: make([]Request, 0)}    readers, teams, players := ReadData("data.txt")    writerChan := make(chan int)          //any2one writers channel    writerFinishChan := make(chan int, 6) // channel to know when all writers are done writing    waitGroup.Add(6)    for i := 0; i < len(teams); i++ {        go Writer(teams, teams[i], writerChan, writerFinishChan)    }    go Manager(&list.List, writerChan)    waitGroup.Wait()}所以现在的问题是，在实施之后select我WaitGroup的程序不再正常工作，它给了我一个“致命错误：goroutines 睡着了，死锁”。也许有人可以帮我解决这个问题？我很确定问题出在函数中Manager并且是select块

Answer 1

看起来您退出Managerfunc 的逻辑现在不同了。在您等待通道关闭之前，但是现在您根本不检查。事实上Manager永远不会退出。这也意味着WaitGroup永远不会完成。

Manager我认为没有必要选择它。如果您要关闭通道，则只需对其进行范围：

for ageIn := range writerChan {

  Add(list, Request{Value: ageIn, Count: 1}) // putting new object to list

}

这将在关闭时正确退出writerChan。