我的main函數(shù)從文件中讀取 json，將其解組為結(jié)構(gòu)體，將其轉(zhuǎn)換為另一種結(jié)構(gòu)體類(lèi)型并通過(guò)標(biāo)準(zhǔn)輸出輸出格式化的 JSON。我正在嘗試實(shí)現(xiàn) goroutines 和通道來(lái)為我的for循環(huán)添加并發(fā)性。func main() { muvMap := map[string]string{"male": "M", "female": "F"} fileA, err := os.Open("serviceAfileultimate.json") if err != nil { panic(err) } defer fileA.Close() data := make([]byte, 10000) count, err := fileA.Read(data) if err != nil { panic(err) } dataBytes := data[:count] var servicesA ServiceA json.Unmarshal(dataBytes, &servicesA) var servicesB = make([]ServiceB, servicesA.Count) goChannels := make(chan ServiceB, servicesA.Count) for i := 0; i < servicesA.Count; i++ { go func() { reflect.ValueOf(&servicesB[i]).Elem().FieldByName("Address").SetString(Merge(&servicesA.Users[i].Location)) reflect.ValueOf(&servicesB[i]).Elem().FieldByName("Date_Of_Birth").SetString(dateCopyTransform(servicesA.Users[i].Dob)) reflect.ValueOf(&servicesB[i]).Elem().FieldByName("Email").SetString(servicesA.Users[i].Email) reflect.ValueOf(&servicesB[i]).Elem().FieldByName("Fullname").SetString(Merge(&servicesA.Users[i].Name)) reflect.ValueOf(&servicesB[i]).Elem().FieldByName("Gender").SetString(muvMap[servicesA.Users[i].Gender]) reflect.ValueOf(&servicesB[i]).Elem().FieldByName("Phone").SetString(servicesA.Users[i].Cell) reflect.ValueOf(&servicesB[i]).Elem().FieldByName("Username").SetString(servicesA.Users[i].Username) goChannels <- servicesB[i] }() } for index := range goChannels { json.NewEncoder(os.Stdout).Encode(index) }}它編譯但返回如下消息：goroutine 1 [chan receive]: main.main() C://.....go.94 +0x55b.
通過(guò) for 循環(huán)的 goroutine 通道
達(dá)令說(shuō)
2021-10-18 11:08:30
