程序代碼片段是這樣的:

maxPage := *flagMaxPage
        if maxPage > 0 {
            jobs := make(chan int, maxPage)
            results := make(chan []map[string]string, maxPage)
            // 招聘10個工人，讓他們工作（待命），每個工人會從jobs管道里獲得任務(wù)，工人干活，把結(jié)果放到results管道
            for w := 1; w <= 10; w++ {
                go doWork(jobs, results)
            }
            //分配任務(wù)
            for j := 1; j <= maxPage; j++ {
                jobs <- j
            }
            close(jobs)
            //db connect
            db, err := mysqlUtil.CreateReadDb()
            defer db.Close()
            if err != nil {
                log.Fatal("connect db err ", err)
                fmt.Println("connect db err ", err)
            }
            //處理結(jié)果
            for j := 1; j <= maxPage; j++ {
                data := <-results
                //這里做查詢和入庫操作
                doDb(db, data)
                fmt.Println(len(data))
            }
            close(results)
            fmt.Println("all done...")
        }

doDb函數(shù)如下：

func doDb(db *sql.DB,data []map[string]string) {
    if data != nil {
        for _, v := range data {
            if v == nil {
                continue
            }
            if v["title"] == "" {
                continue
            }
            if v["url"] == "" {
                continue
            }
            //寫入數(shù)據(jù)庫
            sqlStr := `select * from film where title_md5 ='` + Md5(v["title"]) + `'`
            rows, err := db.Query(sqlStr)
            if err != nil {
                fmt.Println("query err1 ", err)
                continue
            }
            existData, err := mysqlUtil.GetRow(rows)
            if err != nil {
                fmt.Println("query err2 ", err)
                continue
            }
            //如果為空,就插入數(shù)據(jù)
            if len(existData) == 0 {
                score := v["score"]
                scoreVal, err := strconv.ParseFloat(score, 64)
                if err != nil {
                    fmt.Println("insert data parse score error ", err)
                    continue
                }
                f1 := decimal.NewFromFloat(scoreVal)
                f2 := decimal.NewFromFloat(100)
                aaa := f1.Mul(f2).IntPart()
                insertScore := strconv.Itoa(int(aaa))
                titleMd5 := Md5(v["title"])
                sqlInsert := `insert into film(title, img, uptime, url, score, title_md5) values ('` + v["title"] + `', '` + v["img"] + `', '` + v["uptime"] +
                    `','` + v["url"] + `','` + insertScore + `','` + titleMd5 + `')`
                db.Query(sqlInsert)
            }
        }
    }
}

測試了一下，大概跑20個協(xié)程，doDb這個函數(shù)的第二個參數(shù)一次最多15條數(shù)據(jù)，在執(zhí)行到16個協(xié)程的結(jié)果后，就會在fmt.Println("query err1 ", err)這個地方報大量 ：

query err1  dial tcp: lookup xxxx.com: no such host

在包這個錯誤的時候，我手動執(zhí)行

nslookup xxxx.com

解析是正常的。請問一下，這是為啥呢？doDb這個函數(shù)是一個一個處理result的，一共才20*15條記錄，為啥會出現(xiàn)這種問題呢？