需求是這樣的：需要查詢數(shù)據(jù)庫里面的數(shù)據(jù)，然后生成對(duì)應(yīng)格式的xml，打算用協(xié)程實(shí)現(xiàn)，我的大致思路是這樣的：查詢出總數(shù)據(jù)量，然后根據(jù)配置的每個(gè)xml的數(shù)據(jù)個(gè)數(shù)，計(jì)算出需要生成多少個(gè)xml，每個(gè)xml就啟動(dòng)一個(gè)協(xié)程去執(zhí)行生成xml，代碼已經(jīng)寫完，但是經(jīng)常跑一會(huì)就卡主不執(zhí)行了。。不知道為啥，有大神指導(dǎo)一下，或者提供一個(gè)更加好的思路么，數(shù)據(jù)量不多，26萬條左右。。如下是協(xié)程代碼：

func getSiteMaps(db *sql.DB, offset int64, size int64, c chan Sitemap) {
    fmt.Println("offset in channel:", offset)
    sql := "select a.id as outerID,a.name,a.sale_price as price, a.category_id,a.market_price as value,b.name as brand from item as a left join item_brand as b on a.brand_id = b.id where a.status = 1 order by a.id asc limit " + strconv.FormatInt(offset, 10) + "," + strconv.FormatInt(size, 10)
    var r Urlset   //初始化xml
    var urls []Url //初始化urls
    //查詢具體的數(shù)據(jù)
    if rows, rowsErr := db.Query(sql); rowsErr != nil {
        panic(rowsErr)
    } else {
        for rows.Next() {
            var (
                outerID, name, brand, category_id string
                price, value                      float64
            )
            rows.Scan(&outerID, &name, &price, &category_id, &value, &brand)
            if outerID == "" {
                continue
            }
            //loc獲取
            _loc := getLocUrl(outerID)
            //通過categoryId獲取分類信息
            _categoryInfo := getCategoryInfoByParentId(category_id, db)
            // fmt.Println(_categoryInfo)
            // os.Exit(1)
            if _categoryInfo["categoryId"] == "" {
                continue
            }
            //獲取商品圖片
            _imgs := getImages(outerID, db)
            if len(_imgs) <= 0 {
                continue
            }
            _firstImg := ""
            var _moreImages []Images
            for i, v := range _imgs {
                if i == 0 {
                    _firstImg = v
                } else {
                    _moreImages = append(_moreImages, Images{InnerText: v, Index: i})
                }
            }
            moreImages := Mimages{Img: _moreImages}
            // moreImages := _moreImages
            subAttribute := []SubAttribute{SubAttribute{Key: "ext_down_load", Value: "https://m.mia.com/detail-a-" + outerID + ".html"}, SubAttribute{Key: "ext_put_url", Value: "https://m.mia.com/detail-a-" + outerID + ".html"}}
            //Data數(shù)據(jù)
            _choice := Attribute{Attribute: subAttribute}
            itemData := Data{
                OuterID:          outerID,
                Name:             name,
                Price:            price,
                Value:            value,
                PriceUnit:        _PRICE_UNIT,
                Availability:     _AVAILABILITY,
                Image:            _firstImg,
                MoreImages:       moreImages,
                Brand:            brand,
                Loc:              _loc,
                PcLoc:            getPcLoc(outerID),
                SellerSiteUrl:    _SELLER_SITE_URL,
                ShopName:         _SHOP_NAME,
                SearchWiseUrl:    getSearchWiseUrl(outerID),
                Category:         _categoryInfo["categoryName"],
                CategoryUrl:      getCategoryUrl(category_id),
                CategoryPcUrl:    getCategoryPcUrl(category_id),
                SubCategory:      _categoryInfo["subCategoryName"],
                SubCategoryUrl:   getCategoryUrl(_categoryInfo["subCategoryId"]),
                SubcategoryPcUrl: getCategoryPcUrl(_categoryInfo["subCategoryId"]),
                Choice:           _choice,
                SellerName:       _SELLER_NAME,
                Logo:             _LOGO}
            // fmt.Println(itemData)
            // os.Exit(1)
            //url數(shù)據(jù)
            itemUrl := Url{Loc: _loc, Data: itemData}
            //urls數(shù)據(jù)
            urls = append(urls, itemUrl)

        }
        //生成xml數(shù)據(jù)
        r.Url = urls
    }
    //生成xml文件
    if len(urls) > 1 {
        //取數(shù)據(jù),
        fileName := getXmlName(offset, size)
        generateXml(fileName, r, func() {
            xmlUrl := _URL_PREFIX + fileName
            itemSiteMap := Sitemap{Loc: xmlUrl, Lastmod: getCurrentTime()}
            // sitemap = append(sitemap, itemSiteMap)
            //需要停頓幾秒，待寫文件完畢。主要是防止最后一次寫文件沒寫完，程序就執(zhí)行完退出
            time.Sleep(5)
            fmt.Println("done...", offset)
            c <- itemSiteMap
        })
    }
}

如下是main里面的內(nèi)容：

func main() {

    db, dbErr := sql.Open("mysql", _DB)
    if dbErr != nil {
        fmt.Println("db connection err")
        os.Exit(1)
    } else {
        fmt.Println("db ok")
    }
    sql2 := "select count(*) as total from item as a left join item_brand as b on a.brand_id = b.id where a.status = 1"
    var total float64
    if rowCountErr := db.QueryRow(sql2).Scan(&total); rowCountErr != nil {
        panic(rowCountErr)
    } else {
        fmt.Println("total:", total)
        //根據(jù)條數(shù)，獲取協(xié)程數(shù)量
        pages := int(math.Ceil(total / _NUM_PER_XML))
        ch := make(chan Sitemap, pages)
        for i := 0; i <= pages; i++ {
            var offset int64
            if i > 0 {
                offset = int64(_NUM_PER_XML*i + 1)
            }
            go getSiteMaps(db, offset, _NUM_PER_XML, ch)
        }
        for v1 := range ch {

            fmt.Println("val:", v1)
        }
    }
}

新手，求指導(dǎo)？