我对使用100个工作人员来处理3000个查询并确保每个工作人员都有一个连接(MySQL已经配置了超过100个连接)非常陌生。这是我的尝试:
package main
import (
"database/sql"
_ "github.com/go-sql-driver/mysql"
)
var query *sql.Stmt
func worker(jobs <-chan int, results chan<- int) {
for _ = range jobs {
_, e := query.Exe