1 回答

TA貢獻1811條經驗 獲得超5個贊
我沒有嘗試運行這個(因為它需要額外的代碼),但相信你的問題是:
wgD.Add(2)
for i := 1; i < 2; i++{
go test(dateChan, customer, &wgD)
}
該 for 循環只會迭代一次,但您調用了 wgD.Add(2) (我認為您可能意味著循環迭代兩次;嘗試i <= 2)。
另一點反饋;您使用等待組的方式會起作用,但很難遵循(可能導致您沒有發現問題);怎么樣:
func Run(){
SyncCustomerMetricsHistory() // No wait group needed as this will not return before done
}
func SyncCustomerMetricsHistory(){
odb := orm.NewOrm()
start := time.Now()
logs.Info("start sync customer metrics, time:[%v]", start)
qs := odb.QueryTable("gg_customer")
var customers []*db.GgCustomer
if num, err := qs.All(&customers); err != nil || num == 0 {
logs.Error("Get customer error, rows:[%v], err:[%v]", num, err)
}
customersChan := make(chan *db.GgCustomer, 50)
var wgC sync.WaitGroup
wgC.Add(50)
for i := 0; i < 50; i++ {
go func() {
syncCustomerMetricsHistory(customersChan)
wgC.Done()
}()
}
go func() {
for _, customer := range customers {
customersChan <- customer
}
close(customersChan)
}()
wgC.Wait()
}
func syncCustomerMetricsHistory(customerChan <- chan *db.GgCustomer){
for customer := range customerChan{
dateChan := make(chan string, 2)
var wgD sync.WaitGroup
wgD.Add(2)
for i := 1; i < 2; i++{
go func() {
test(dateChan, customer)
wgD.Done()
}()
}
go func(){
for _, date := range GetAllYearDate(){
dateChan <- date
}
close(dateChan)
}()
wgD.Wait()
}
}
}
我認為這更容易理解,因為您可以看到 wg.Done() 被調用的位置。在兩側粘貼一些 fmt.Println 命令也非常容易,這使得調試此類問題變得更簡單。
- 1 回答
- 0 關注
- 192 瀏覽
添加回答
舉報