使用带 select 的通道时 Goroutine 死锁

在Golang实战开发的过程中，我们经常会遇到一些这样那样的问题，然后要卡好半天，等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《使用带 select 的通道时 Goroutine 死锁》，聊聊，希望可以帮助到正在努力赚钱的你。

我尝试重写一个不使用 select 或 waitgroup 的工作程序，以便它实现 select 和 waitgroup，但我遇到了一个问题，我找不到解决方案。看来发生了goroutine死锁，因为manager函数没有从writer通道获取数据，因此通道被阻止发送/接收，程序被锁定。

原始工作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，有更新的代码：

使用 select 实现更新了 manager 函数：

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
        }
    }
}

使用 waitgroup 实现更新了 main 函数：

var waitgroup sync.waitgroup

func 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()
}

writer函数将数据发送到writerchan

func Writer(teams [][]Player, team []Player, writerChan chan<- int,
    writerFinishChan chan int) {
    defer waitGroup.Done()
    count := len(team)
    for i := 0; i < count; i++ {
        writerChan <- team[i].Age
    }
    writerFinishChan <- 1 // when writer finishes writing, he puts 1 to the "writerFinishChan"

    if len(writerFinishChan) == len(teams) { // if all writers are done writing (the len should be equal to 6)
        close(writerChan)
    }
}

所以现在的问题是，在实现 select 和 waitgroup 后，我的程序不再正常工作，它给了我一个“致命错误：goroutines 睡着了，死锁”。

也许有人可以帮我解决这个问题？我很确定问题出在 manager 函数中，它是 select 块

解决方案

看来您退出 manager 函数的逻辑现在有所不同。在您等待通道关闭之前，但现在您根本不检查。事实上manager永远不会退出。这也意味着 waitgroup 永远不会完成。

我认为在manager中选择没有必要。如果您要关闭通道，则只需在其上范围即可：

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

当 writerchan 关闭时，这将正确退出。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《使用带 select 的通道时 Goroutine 死锁》文章吧，也可关注golang学习网公众号了解相关技术文章。