Почему мой канал Голанг пишет блокировку навсегда?

Question

Я пытаюсь провести качели на параллелизм в Голанге, реорганизовывая одну из моих утилит командной строки за последние несколько дней, но я застрял.

Here's Оригинальный код (главная ветка).

Here's ветка с параллелизмом (ветка x_concurrent).

Выполнения параллельного кода go run jira_open_comment_emailer.go, то defer wg.Done() никогда не выполняется, если проблема JIRA добавляется в канал here, что вызывает мое 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

В goroutines блок на отправку в небуферизованном канала. Минимального изменения разблокирует goroutines является созданием буферного канала с емкостью для всех вопросов:

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

и закрыть канал после вызова wg.Wait().