如果进程在与我们的应用程序服务器不同的 cpu 上继续,使用 async/await 方法会非常有用。
例如,数据库查询在数据库服务器上运行,查询运行时无需阻塞应用程序线程。你可以从这里查看。
让我们看看那个 c# 代码块
public async Task SaveAsync(User user)
{
using (DataContext ctx = new DataContext())
{
ctx.User.Add(user);
// database does its job while we are waiting
await ctx.SaveChangesAsync();
}
}
那么下面的 goroutine 代码有同样的效果吗?
func (u *User) Create(userModel *model.User) error {
var err error
var wg sync.WaitGroup
//or channel can be used for sync
wg.Add(1) //wg := make(chan int)
go func() {
defer wg.Done(). //wg <- 1
_, err = u.Transaction.User.
Create().
SetAge(userModel.Age).
SetName(userModel.Name).
SetIsDeleted(false).
Save(u.Ctx)
}()
wg.Wait() // <-wg
if err !=nil{
return err
}
return nil}
呼如林
相关分类