【发布时间】：2021-12-30 00:55:41
【问题描述】：
我正在尝试在我的 API 中使用 Goroutine。我需要检查我使用的方法是否正确或是否需要改进。
我正在使用 go 创建 REST-API。也使用 SQL-boiler。
在我的许多 API 中，我使用了一些其他功能，例如使用 AWS 发送通知、使用 AWS 发送电子邮件、Mailchimp 集成。
一些 APIS 使用这 3 个特性而不是我们的数据库活动。
所以我发现在 API 中显示结果需要一些时间。然后我找到了 Goroutine 和等待组。
在这里，我不想花时间来完成我的 api。但我想超越代码背后的其他功能。
所以我刚刚检查了一下，我对 goroutine 和等待组感到困惑。 当我在 3 个功能中使用等待组时，我明白......在完成所有功能后，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在数据库操作后返回成功，其他goroutine会在后台运行
我还有一个双人间
如果我使用用户的 for 循环。我需要为每个用户更新一些数据..
for _, user := range userDetails {
// calling auth 0
// calling mailchimp
// calling aws
}
我需要为每个用户更新数据
那么我的问题是使用 goroutine 的最佳方法是什么？
方法一
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)
}
哪种方法最好？
【问题讨论】：
-
是的，启动痛风的经过时间小于启动goroutines并等待goroutines完成的经过时间。
-
@PenélopeStevens，你的意思是，我们需要使用 waitgroup 吗？我觉得使用 waitgroup 比使用 goroutine 还要花时间
-
WaitGroup 唯一需要的时间是 goroutine 完成的时间，即如果 goroutines 都调用了
Done()，则不需要时间。如果您需要等待 goroutines 完成，那么等待是正确性的问题，而不是执行时间。 -
@MiaMia 如果其中一个 goroutine 发生故障，应用程序是否需要向调用者返回错误？如果是这样，应用程序应该等待 goroutine 并为每个 goroutine 获取错误状态（errgroup 可能对此有用）。