使用Go协程和等待组

从现在开始，我们要努力学习啦！今天我给大家带来《使用Go协程和等待组》，感兴趣的朋友请继续看下去吧！下文中的内容我们主要会涉及到等等知识点，如果在阅读本文过程中有遇到不清楚的地方，欢迎留言呀！我们一起讨论，一起学习！

问题内容

我正在尝试在我的 api 中使用 goroutine。我需要检查我使用的方法是否正确或者是否需要改进。

我正在使用 go 创建 rest-api。也使用 sql-boiler。

在我的许多 api 中，我使用了一些其他功能，例如使用 aws 发送通知、使用 aws 发送电子邮件、mailchimp 集成。

一些 api 使用这 3 个功能而不是我们的数据库活动。

所以我发现 api 需要一些时间来显示结果。然后我找到了 goroutine 和 wait-group。

在这里，我不想花时间来完成我的 api。但我想超越代码背后的其他功能。

所以我刚刚检查了一下，我对 goroutine 和 wait-group 感到困惑。 当我在 3 个功能中使用 wait-group 时，我明白..完成所有功能后 api 会给出响应。

但是，当使用 goroutine api 时，很容易给出响应，并且其他功能正在后台执行。

使用 goroutine api 比 waitgroup 花费的时间更少..

这是正确的吗？ 我的方法是否正确？或者我的工作流程中缺少什么？

{
if impartwealthids != "" {
        impartwealthids = strings.trim(impartwealthids, ",")
        updateuser := fmt.sprintf(`update user 
        set deleted_at='%s' ,
         email=concat(email, "-", impart_wealth_id),
         screen_name=concat(screen_name, "-", impart_wealth_id),
         deleted_by_admin=true 
         where impart_wealth_id in(%s);
        `, golangdatetime, impartwealthids)

        query = updateuser
    }
    _, err = queries.raw(query).execcontext(ctx, m.db)
    m.logger.info(query)
    if err != nil {
        m.logger.error("query failed", zap.any("query", err))
        return err
    }
    go func() {
        for _, user := range userdetails {
            email := fmt.sprintf("%s-%s", user.impartwealthid, user.email)
            userup := management.user{
                email: &email,
            }
            err = mngmnt.user.update(*&user.authenticationid, &userup)
            if err != nil {
                m.logger.error("auth update failed", zap.any("user.email", user.email), zap.any("query", err))
            }
        }
    }()
    go impart.userdemographicsupdate(ctx, m.db, true, true)
        if user.r.memberhivehives != nil {
            if user.r.memberhivehives[0].notificationtopicarn.string != "" {
                go func() {
                    err := m.notificationservice.unsubscribetopicforalldevice(ctx, user.impartwealthid, user.r.memberhivehives[0].notificationtopicarn.string)
                    if err != nil {
                        m.logger.error("subscribetopic", zap.string("devicetoken", user.r.memberhivehives[0].notificationtopicarn.string),
                            zap.error(err))
                    }
                }()
            }
        }
    go impart.userdemographicsupdate(ctx, m.db, true, true)
    return "success"
}

此处api在数据库操作后返回成功，其他goroutines将在后台运行

我还有一个双人床

如果我使用用户的 for 循环。我需要为每个用户更新一些数据..

for _, user := range userdetails {
// calling auth 0
// calling mailchimp
// calling aws
}

我需要更新每个用户的数据

那么我的问题是哪种是使用 goroutine 的最佳方法？

方法1

for _, user := range userdetails {
        go calling auth 0
        go calling mailchimp
        go calling aws

        }

方法 - 2

for _, user := range userDetails {
        go func(user *dbmodels.User) {
            // calling auth 0
            // calling mailchimp
            // calling aws
        }(user)
            }

哪一种是最好的方法？

正确答案

这两种建议的方法可能不适用于大量数据，这两种方法都会分别创建 3N 和 N 个 goroutine，这足以使大量用户的系统崩溃。 使用工作池将是最好的解决方案，可以使用任何您觉得方便的方法。这样您就可以限制呼叫。 参考：https://gobyexample.com/worker-pools

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《使用Go协程和等待组》文章吧，也可关注编程网公众号了解相关技术文章。