Goroutine 循环未完成

哈喽！今天心血来潮给大家带来了《Goroutine 循环未完成》，想必大家应该对Golang都不陌生吧，那么阅读本文就都不会很困难，以下内容主要涉及到，若是你正在学习Golang，千万别错过这篇文章~希望能帮助到你！

我正在尝试循环遍历数组并复制数组中的每个值。我想将每个循环放在一个单独的 goroutine 中。当我使用 goroutine 运行它时，将循环比数组大小 (len(array) -1) 小一的循环，但如果我摆脱 goroutine，那么它处理得很好。

我是否遗漏了一些关于它应该如何工作的信息？运行 goroutine 时总是少一，这似乎很奇怪。下面是我的代码。

func createeventsforeachworkoutreference(plan *sharedstructs.plan, user *sharedstructs.user, starttime time.time, timezonekey *string, transactionid *string, monitoringchannel chan interface{}) {
    //set the activity type as these workouts are coming from plans
    activitytype := "workout"
    for _, workoutreference := range plan.workoutreferences {
        go func(workoutreference sharedstructs.workoutreference) {
            workout, getworkouterror := workout.getworkoutbyname(workoutreference.workoutid.id, *transactionid)
            if getworkouterror == nil && workout != nil {
                //for each workout, create a reference to be inserted into the event
                reference := sharedstructs.reference{id: workout.workoutid, type: activitytype, index: 0}
                referencearray := make([]sharedstructs.reference, 0)
                referencearray = append(referencearray, reference)
                event := sharedstructs.event{
                    eventid:       uuidhelper.generateuuid(),
                    description:   workout.description,
                    type:          activitytype,
                    userid:        user.userid,
                    ispublic:      false,
                    references:    referencearray,
                    eventdatetime: starttime,
                    planid:        plan.planid}
                //insert the event into the databse, i don't handle errors intentionally as it will be async
                creationerror := eventdomain.createnewevent(&event, transactionid)
                if creationerror != nil {
                    redfalconlogger.logcritical("plan.createeventsforeachworkoutreference() error creating a workout"+creationerror.error(), *transactionid)
                }
                //add to the outputchannel
                monitoringchannel <- event
                //calculate the next start time for the next loop
                starttime = calculatenexteventtime(&starttime, &workoutreference.resttime, timezonekey, transactionid)
            }
        }(workoutreference)
    }
    return
}

经过更深入的研究，我认为我找到了根本原因，但还没有找到（优雅的）解决方案。

似乎发生的情况是，我的调用函数也在异步 goroutine 中运行，并使用“chan 接口{}”来监视进度并将进度流回客户端。在数组中的最后一项上，它正在完成调用 goroutine，然后才能在上游处理 chan。

等待通道处理完成的正确方法是什么。下面是我用来提供上下文的单元测试的一部分。

var wg sync.WaitGroup
wg.Add(1)
go func() {
    defer wg.Done()
    createEventsForEachWorkoutReference(plan, &returnedUser, startDate, &timeZone, &transactionID, monitoringChan)
}()
var userEventArrayList []sharedstructs.Event
go func() {
    for result := range monitoringChan {
        switch result.(type) {
        case sharedstructs.Event:
            counter++
            event := result.(sharedstructs.Event)
            userEventArrayList = append(userEventArrayList, event)
            fmt.Println("Channel Picked Up New Event: " + event.EventID + " with counter " + strconv.Itoa(counter))
        default:
            fmt.Println("No Match")
        }
    }
}()
wg.Wait()
//I COULD SLEEP HERE BUT THAT SEEMS HACKY
close(monitoringChan)

想要再添加一个示例（没有我的自定义代码）。您可以注释掉 sleep 行以查看它与 sleep 的配合情况。

https://play.golang.org/p/t6l_c4zscp-

解决方案

终于找到答案了...

问题是我需要在第一个 goroutine 中关闭监视Chan，然后在第二个 goroutine 中监视（Defer wg.close()）。当我这样做时效果很好！

https://play.golang.org/p/fEaZXiWCLt-

今天关于《Goroutine 循环未完成》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！