为什么我的 Golang 通道写永远阻塞？

Question

过去几天我一直试图通过重构我的一个命令行实用程序来改变 Golang 的并发性，但我陷入了困境。

这是原始代码（主分支）。

这是并发分支（x_concurrent分支）。

当我使用

go run jira_open_comment_emailer.go

执行并发代码时，如果将 JIRA 问题添加到通道

here

，defer wg.Done() 永远不会执行，这会导致我的

wg.Wait()

永远挂起。

我的想法是，我有大量 JIRA 问题，我想为每个问题分离一个 goroutine，看看它是否有我需要回复的评论。如果是这样，我想将其添加到某种结构中（经过一番研究后我选择了一个频道），稍后我可以像队列一样读取它以建立电子邮件提醒。

这是代码的相关部分：

// Given an issue, determine if it has an open comment
// Returns true if there is an open comment on the issue, otherwise false
func getAndProcessComments(issue Issue, channel chan<- Issue, wg *sync.WaitGroup) {
    // Decrement the wait counter when the function returns
    defer wg.Done()

    needsReply := false

    // Loop over the comments in the issue
    for _, comment := range issue.Fields.Comment.Comments {
        commentMatched, err := regexp.MatchString("~"+config.JIRAUsername, comment.Body)
        checkError("Failed to regex match against comment body", err)

        if commentMatched {
            needsReply = true
        }

        if comment.Author.Name == config.JIRAUsername {
            needsReply = false
        }
    }

    // Only add the issue to the channel if it needs a reply
    if needsReply == true {
        // This never allows the defered wg.Done() to execute?
        channel <- issue
    }
}

func main() {
    start := time.Now()

    // This retrieves all issues in a search from JIRA
    allIssues := getFullIssueList()

    // Initialize a wait group
    var wg sync.WaitGroup

    // Set the number of waits to the number of issues to process
    wg.Add(len(allIssues))

    // Create a channel to store issues that need a reply
    channel := make(chan Issue)

    for _, issue := range allIssues {
        go getAndProcessComments(issue, channel, &wg)
    }

    // Block until all of my goroutines have processed their issues.
    wg.Wait()

    // Only send an email if the channel has one or more issues
    if len(channel) > 0 {
        sendEmail(channel)
    }

    fmt.Printf("Script ran in %s", time.Since(start))
}

Answer 1

goroutine 会阻塞发送到无缓冲通道。 解除 goroutine 阻塞的最小更改是创建一个能够解决所有问题的缓冲通道：

channel := make(chan Issue, len(allIssues))

并在调用 wg.Wait() 后关闭通道。

Answer 2

请务必注意，使用未初始化 (

nil

) 的通道发送或接收将永远阻塞（请参阅关闭通道与零通道）。

所以可能发生的情况是，您要么未能初始化通道，要么，在初始化之后，通道变量已通过

nil

赋值以某种方式重置（可能是由于代码中其他地方的错误）。

总结：仔细检查您的频道是否为

nil

log.Printf("About to use channel %v", mychannel)