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

Posted 2023-03-14

【中文标题】使用带有选择的通道时的 Goroutine 死锁

【英文标题】：Goroutine deadlock when using a channel with select

【发布时间】：2019-05-04 23:23:13

【问题描述】：

我试图重写一个没有使用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, RequestValue: 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, RequestValue: ageIn, Count: 1) // add player to list
        default:
            break
        
    

更新了Main 函数，实现WaitGroup：

var waitGroup sync.WaitGroup

func main() 
    list := ParallelListList: 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 for 循环。您在默认情况下放置了 break，但 select 的行为与 switch 相同，因此它只是打破了默认情况，而不是 for 循环。

我想过给循环贴一个标签，f.e. Loop : for .. 然后将 break Loop 放在默认情况下，但我不确定这是解决此问题的正确方法。

@Dariuha：虽然这里还有其他问题，但如果您将代码构造为使用早期的return，那么打破嵌套块通常是最容易的。

【参考方案1】：

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

我认为Manager 中的选择没有必要。如果您要关闭通道，则只需覆盖它：

for ageIn := range writerChan 
  Add(list, RequestValue: ageIn, Count: 1) // putting new object to list

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

【讨论】：

感谢您的意见。但是是不是需要select 来确保程序同时工作？这是我认为我需要实现select 块的唯一原因。

不完全。选择允许您在一个地方/执行例程中对多个通道进行操作。 Go 例程可以让你同时做一些事情。

我仍然想弄清楚在这种情况下如何实现 select 块。所以早些时候我检查了writerChan 是否打开，所以我会知道何时中断循环。使用select 时可能会出现什么情况，也许您有什么想法可以让它工作吗？

看看 go tour 关于何时使用选择的示例：tour.golang.org/concurrency/5。要让 select 知道通道是否关闭，您实际上会执行与之前相同的操作：case ageIn, writersOpen := <- writerChan

所以在case ageIn, writersOpen := <- writerChan 中，我需要一个if 语句if writersOpen ... doing my stuff... 和else 中的if 我应该退出Manager，应该怎么做？我认为使用 break 应该可以，但它只退出 case 而不是 Manager 本身。