なぜ私のGolangチャンネル書き込み禁止永遠にですか？

Question

私はGolangの同時実行で、数日間にわたって私のコマンドラインユーティリティの1つをリファクタリングすることによってスイングを試みてきましたが、私は立ち往生しています。

Here's元のコード（マスターブランチ）。

Here's並行性のあるブランチ（x_concurrentブランチ）。

私はgo run jira_open_comment_emailer.goと並行コードを実行するとJIRAの問題は私のwg.Wait()は永遠にハングアップしたチャネルhereに追加された場合、defer wg.Done()が実行されることはありません。

私は大量のJIRAの問題を抱えています。私は応答する必要があるコメントがあるかどうかを確認するために、それぞれについてゴルーチンをスピンオフしたいと考えています。それがある場合は、後でキューのように読むことができて、電子メールリマインダーを構築する構造（いくつかの研究の後にチャネルを選択しました）に追加したいと思います。ゴルーチンがバッファリングされていないチャネルに送信をブロック

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

：

は、ここでは、コードの該当部分です。

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

と）（wg.Waitへの呼び出し後にチャンネルを閉じる： 最小限の変更はゴルーチンのブロックを解除すると、すべての問題のために容量のバッファリングされたチャネルを作成することです。