找不到死锁问题的根本原因

该代码试图使用信号通道来控制工作程序，但遇到死锁问题。从代码中移除信号通道后，代码可以正常运行。为了找到死锁的根本原因，可以尝试使用工具，例如 `go tool trace`，来分析程序的执行情况。另外，将生成作业的任务放入单独的 goroutine 中可以解决死锁问题。

无法找到此代码死锁的原因。这里的目的是让工作程序 go 例程仅在收到信号后才执行一些工作。

如果从代码中删除 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)
    }

}

正确答案

在单独的 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

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《找不到死锁问题的根本原因》文章吧，也可关注golang学习网公众号了解相关技术文章。