新手想请教一个协程批处理任务的问题

jayxtt999 · · 1385 次点击 · 开始浏览    置顶

``` package main import ( "encoding/json" "log" "sync" ) var ResData []ItemData var ch = make(chan ItemData) func do(u UserRes,item ItemData,p Param, waitGroup *sync.WaitGroup) { defer waitGroup.Done() //do something 5-10s item.money_total = 1 ch<-item } func main() { sql := "SELECT id FROM user limit 10000" rows, err := dbCon.Queryx(sql) if err != nil { log.Fatalf("err: %v", err) } defer rows.Close() var wg sync.WaitGroup for rows.Next() { wg.Add(1) var u UserRes var item ItemData err = rows.StructScan(&u) if err != nil { log.Fatalf("err: %v", err) } go do(u,item,p,&wg) ResData = append(ResData,<- ch) } json, err := json.Marshal(ResData) if err != nil { log.Fatalf("JSON ERR: %v", err) } wg.Wait() } ``` 这上面是部分代码示意 大概需求就是我需要给每个用户生成一份报表。每个用户生成时间大概就是5-10s,但是用户比较多 然后我发现我这样写好像还是需要很久的时间才能全部处理完 感觉是我对哪块的理解有问题或者是哪里阻塞了。 或者大佬们一般这种任务是怎么处理的。用什么组件

有疑问加站长微信联系(非本文作者)

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1385 次点击  
加入收藏 微博
6 回复  |  直到 2022-07-07 10:14:56
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传