我有一個帶有開關(guān)的 goroutine，它想要將一個接口附加到一個結(jié)構(gòu)體，但是當運行它時，我沒有收到錯誤，但它沒有附加任何響應(yīng)，你如何在 Go 中編寫它以使其并發(fā)安全？這是我的代碼：var wg sync.WaitGroupfor _, v := range inputParameters.Entities { go func(v domain.Entity) { wg.Add(1) defer wg.Done() var f func( v domain.Entity, result *domain.Resoponse, )(interface{}, Error) // Signature of all Get methods switch v.Name { case "process1": f = 1Processor{}.Get case "process2": f = 2Processor{}.Get case "process3": f = 3Processor{}.Get default: return } res, err := f(v, result) if err != nil { mapError.Error = append(mapError.Error, err) } else { result.Mu.Lock() defer result.Mu.Unlock() result.Entities = append(result.Entities, res) } }(v)}wg.Wait()return result, mapError作為參考，這里是Response類型：type Resoponse struct { Mu sync.Mutex Entities []interface{}}
1 回答
小唯快跑啊
TA貢獻1863條經(jīng)驗 獲得超2個贊
wg.Add(1)在 goroutine 之前執(zhí)行。無法保證 goroutine 中的任何邏輯在您到達之前就已完成，wg.Wait()因此不要將wg.Add(1)s 放入 goroutine 中。
- 1 回答
- 0 關(guān)注
- 143 瀏覽
添加回答
舉報
0/150
提交
取消