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

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，但是用户比较多 然后我发现我这样写好像还是需要很久的时间才能全部处理完 感觉是我对哪块的理解有问题或者是哪里阻塞了。 或者大佬们一般这种任务是怎么处理的。用什么组件