无法找到 go 死锁的原因

Question

无法找到此代码死锁的原因。此处的目的是让工作人员仅在收到信号后才执行例行程序。

如果从代码中删除 signalStream 通道，它可以正常工作。但是当它被引入时，它就会陷入僵局。不确定这是为什么。另外，如果有什么工具可以解释死锁的发生，那将有所帮助。

package main

import (
    "log"
    "sync"
)

const jobs = 10
const workers = 5

var wg sync.WaitGroup

func main() {

    // create channel
    dataStream := make(chan interface{})
    signalStream := make(chan interface{})

    // Generate workers

    for i := 1; i <= workers; i++ {
        wg.Add(1)
        go worker(dataStream, signalStream, i*100)
    }

    // Generate jobs

    for i := 1; i <= jobs; i++ {
        dataStream <- i
    }
    close(dataStream)

    // start consuming data
    close(signalStream)

    wg.Wait()

}

func worker(c <-chan interface{}, s <-chan interface{}, id int) {
    defer wg.Done()
    <-s

    for i := range c {
        log.Printf("routine - %d - %d \n", id, i)
    }

}

Answer 1

在单独的 gorouine 中生成作业，即将整个 jobs 循环放入 goroutine 中。如果你不这样做，那么 dataStream <- i 将被阻止，你的程序将永远不会“开始消耗数据”

// Generate jobs
go func() {
    for i := 1; i <= jobs; i++ {
        dataStream <- i
    }
    close(dataStream)
}()

https://go.dev/play/p/ChlbsJlgwdE

无法找到 go 死锁的原因

Unable to find reason for go deadlock

go

deadlock