goroutine-with-waitgroup.go

goroutine-with-waitgroup.go

func upsert(user User) {

   var wg sync.WaitGroup

   wg.Add(1)
   go upsertToPostgres(user, &wg)

   upsertToCouchbase(user, "key")

   wg.Wait()
}

func upsertToPostgres(user User, wg *sync.WaitGroup) {
   
   fmt.Println("# upserting userId to two tables in Postgres")
   time.Sleep(20 * time.Millisecond)

   fmt.Println("# upserting userName to one table in Postgres")
   time.Sleep(10 * time.Millisecond)

   wg.Done()
}

func upsertToCouchbase(user User, key string) {
  
   fmt.Println("# upserting to Couchbase")
   time.Sleep(5 * time.Millisecond)
}